zoukankan      html  css  js  c++  java
  • python网络编程--线程Semaphore(信号量)

    一:Semaphore(信号量)

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

    # -*- coding:utf-8 -*-
    __author__ = 'shisanjun'
    #信号锁用于连接池,scoket连接等,用于修改数据又会出现线程锁问题
    
    import threading
    import time
    
    def run(n):
    
        semophore.acquire()
        print(n)
        time.sleep(1)
        semophore.release()
    
    
    if __name__=="__main__":
    
        semophore=threading.BoundedSemaphore(5)#同时5个子线程运行,运行一个在进一个
    
        for i in range(20):
            t=threading.Thread(target=run,args=("t%s" %i,))
            t.start()
    
        while threading.active_count()!=1:
            pass
        else:
            print("11")
  • 相关阅读:
    Linux 系统启动过程
    Linux启动U盘制作
    JSONP 教程
    JSON 使用
    JSON.stringify()
    JSON.parse()
    Apache模块开发指南-APR池
    [C++基础]goto的用法
    atexit()函数
    c++ good books
  • 原文地址:https://www.cnblogs.com/lixiang1013/p/7064963.html
Copyright © 2011-2022 走看看