from threading import BoundedSemaphore
MAX = 3
semaphore = BoundedSemaphore(MAX)
print(semaphore._value)
semaphore.acquire()
print(semaphore._value)
semaphore.acquire()
print(semaphore._value)
print(semaphore.acquire())
print(semaphore._value)
# 如果没有资源可以申请(_value 的值是0), 再次调用acquire方法,会被阻塞
print(semaphore.acquire(False))
print(semaphore._value)
semaphore.release() # 第一次释放资源
print(semaphore._value)
semaphore.release() # 第二次释放资源
print(semaphore._value)
semaphore.release() # 第三次释放资源
print(semaphore._value)
# 无资源被占用,抛出异常
# semaphore.release() # 第四次释放资源
# print(semaphore._value)
3
2
1
True
0
False
0
1
2
3
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。