你的位置:首页 > 信息动态 > 新闻中心
信息动态
联系我们

python—多线程之信号量

2021-10-16 6:33:40

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