一、什么是信号量。
信号量也是一种锁。
信号量的主要用途是用来控制线程的并发量的,BoundedSemaphore或Semaphore管理一个内置的计数器,每调用一次acquire()方法时,计数器-1,每调用一次release()方法时,内部计数器+1。
不过需要注意的是,Semaphore内部的计数器不能小于0!当它内部的计数器等于0的时候,这个线程会被锁定,进入阻塞状态,直到其他线程去调用release方法。
BoundedSemaphore与Semaphore的唯一区别在于前者将在调用release()时检查计数 器的值是否超过了计数器的初始值,如果超过了将抛出一个异常。
二、信号量使用的示例。
#!/usr/local/bin/python2.7
# -*- coding:utf-8 -*-
import threading
import time
semaphore = threading.Semaphore(5) #设置同一次只能最多有5个线程通过。
def func():
if semaphore.acquire():
print threading.currentThread().getName() + "semaphore"
time.sleep(2)
semaphore.release()
for _ in range(20):
t1 = threading.Thread(target=func)
t1.start()
输出运行结果:
Thread-1semaphore
Thread-2semaphore
Thread-3semaphore
Thread-4semaphore
Thread-5semaphore
Thread-6semaphore
Thread-7semaphore
Thread-8semaphore
Thread-9semaphore
Thread-10semaphore
Thread-13semaphore
Thread-11semaphore
Thread-12semaphore
Thread-14semaphore
Thread-15semaphore
Thread-17semaphore
Thread-20semaphore
Thread-19semaphore
Thread-18semaphore
Thread-16semaphore
一次最多放行了5个线程,这个和停车位的概念有点像。
三、信号量与递归锁的区别。
个人理解~信号量和递归锁的差别是不是,在信号量中,同一把锁,多个线程可以操作同一个共享数据,在递归锁在锁被释放之前一个线程只能操作一个共享数据。