一、信号量
设置在多线程中,并行运行的线程个数
我们都知道在加锁的情况下,程序就变成了串行,也就是单线程,而有时,我们在不用考虑数据安全时(不修改数据),不用加锁,程序就变成了并行,也就是多线程。为了避免业务开启过多的线程时。我们就可以通过信号量,(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('主线程执行完毕')