信号量:最古老的同步原语之一,是一个计数器。
当资源释放时,计数器就会递增,当申请资源时,计数器就会递减
可以认为信号量代表资源是否可用。
from threading import BoundedSemaphore MAX = 3 semaphore = BoundedSemaphore(MAX) print(semaphore._value) semaphore.acquire() print(semaphore._value) semaphore.acquire() print(semaphore._value) semaphore.acquire() print(semaphore._value) # blocking=True时,默认。value为0,没有资源可以申请,再次调用方法会被阻塞 # print(semaphore.acquire(blocking=True)) # print(semaphore._value) print(semaphore.acquire(blocking=False)) print(semaphore._value) semaphore.release() print(semaphore._value) semaphore.release() print(semaphore._value) semaphore.release() print(semaphore._value) # 若没有资源被占用,调用释放,会抛出异常 # semaphore.release() # print(semaphore._value) # raise ValueError("Semaphore released too many times") # ValueError: Semaphore released too many times
3
2
1
0
False
0
1
2
3