一、信号量
设置在多线程中，并行运行的线程个数
我们都知道在加锁的情况下，程序就变成了串行，也就是单线程，而有时，我们在不用考虑数据安全时（不修改数据），不用加锁，程序就变成了并行，也就是多线程。为了避免业务开启过多的线程时。我们就可以通过信号量，(Semaphore)来设置指定个数的线程。举个简单例子:车站有3个安检口，那么同时只能有3个人安检，别人来了，只能等着别人安检完才可以过。
二、代码
semapshore = threading.BoundedSemaphore(3) ：一次只允许3个人同时过安检
semapshore.acquire()：获取锁
semapshore.release()：释放锁
import threading
import os, time
# 一次只允许3个人同时过安检
semapshore = threading.BoundedSemaphore(3)
def run(num):
semapshore.acquire() # 获得信号量的锁
print(f'第{num}个人正在过安检')
time.sleep(2)
semapshore.release() # 释放这把锁
if __name__ == '__main__':
# 创建子线程
thread = []
for i in range(100):
t = threading.Thread(target=run, args=(i,))
t.start()
thread.append(t)
for t in thread:
t.join()
print('主线程执行完毕')
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/74375.html
