标签：__ run semaphore 信号量 threading 线程 Semaphore print

互斥锁 同时只允许一个线程更改数据，而Semaphore是同时（无序轮流）允许一定数量（设置参数）的线程更改数据 ，比如厕所有3个坑，那最多只允许3个人上厕所，后面的人只能等里面有人出来了才能再进去。

import threading, time, sys


def run(n):
    semaphore.acquire()
    time.sleep(1)
    sys.stdout.write(f"run the thread: {n}\n") #为解决print方法的线程不安全性（主要是输出换行的问题），此处使用sys.stdout.write方法替代
    semaphore.release()

if __name__ == '__main__':
    num = 0
    semaphore = threading.BoundedSemaphore(5)  # 最多允许5个线程同时运行
    for i in range(20):
        t = threading.Thread(target=run, args=(i,))
        t.start()
    while threading.active_count() != 1:  #等于1时，表示只剩主线程
        pass
    else:
        print('----all threads done---')
        print(num)

标签：__,run,semaphore,信号量,threading,线程,Semaphore,print
来源： https://www.cnblogs.com/bohua320/p/15312509.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。