zoukankan      html  css  js  c++  java
  • python_day10 信号量

     ########可以理解成  同时拥有N把 一样的锁

    同进程的一样

    Semaphore管理一个内置的计数器,
    每当调用acquire()时内置计数器-1;
    调用release() 时内置计数器+1;
    计数器不能小于0;当计数器为0时,acquire()将阻塞线程直到其他线程调用release()。

    实例:(同时只有5个线程可以获得semaphore,即可以限制最大连接数为5):

    import threading
    import time

    semaphore = threading.Semaphore(5)

    def func():
    if semaphore.acquire():
    print (threading.currentThread().getName() + ' get semaphore')
    time.sleep(2)
    semaphore.release()

    for i in range(20):
    t1 = threading.Thread(target=func)
    t1.start()

     与进程池是完全不同的概念,进程池Pool(4),最大只能产生4个进程,而且从头到尾都只是这四个进程,不会产生新的,而信号量是产生一堆线程/进程

  • 相关阅读:
    leetcode-19-merge
    leetcode-18-remove
    R-codes-tips
    python-bioInfo-codes-2
    Java-framework-Vaadin
    leetcode-17-BST
    生物信息学-知识笔记-1
    leetcode-16-greedyAlgorithm
    perl-tips-1
    计算机网络HTTP、TCP/IP包
  • 原文地址:https://www.cnblogs.com/onda/p/7111422.html
Copyright © 2011-2022 走看看