python學習之信號量

若是想要控制同時訪問資源的數量,咱們能夠怎麼作呢？本篇文章將經過信號量的操做來達到這一需求。但願感興趣的小夥伴能夠堅持看下去同時歡迎提出寶貴的意見讓咱們一塊兒進步！

01：信號量

1）概述：信號量是用來控制線程併發數的。

2）原理：BoundedSemaphore和Semaphore管理一個內置的計數器。每當資源釋放遞增時(調用acquire)計數器-1,資源消耗時遞減(調用release)計數器+1。

3）調用格式：threading.BoundedSemaphore/Semaphore(value);值默認1

4）使用場景：停車位(固定的停車位,車位所有被佔用則進不來;只有車子離開其他車才能進來)

5）BoundedSemaphore和Semaphore區別：前者將在調用release()時檢查計數器的值是否超過了計數器的初始值,若是超過將拋出一個異常。

6）注意事項：計數器不能小於0,當計數器爲0時:acquire()將阻塞線程至同步鎖定狀態,直到其餘線程調用release()。

02：案例操做

停車場只有3個停車位。來了5輛汽車須要停車這時候就使用Semaphore來控制訪問量了
只能同時容許3輛車同時進入停車場,第4輛車只有等先進入的3輛車中有車出來纔可進入

import threading,time,random
semaphore=threading.Semaphore(3)#同一時間只能有3個線程處於運行狀態
def run (ii):
    semaphore.acquire() # 得到信號量:信號量減一
    print(ii,'號車能夠進入')
    time.sleep(random.randint(0,10)*1)
    print(ii,'號停車位釋放')
    semaphore.release()# 釋放信號量:信號量加一
for i in range(5):#建立5個線程
    t=threading.Thread(target=run,args=(i,))
    t.start()

03：BoundedSemaphore和Semaphore區別案例操做

BoundedSemaphore調用時若是計數器的值超過了初始值會拋出異常;可是Semaphore不會

import threading,time,randomsemaphore=threading.BoundedSemaphore(3)#同一時間只能有3個線程處於運行狀態def run (ii):    semaphore.acquire() # 得到信號量:信號量減一    print(ii,'號車能夠進入')    time.sleep(random.randint(0,10)*1)    print(ii,'號停車位釋放')    #***************此處高能******************    semaphore.release()# 釋放信號量:信號量加一    # 再次釋放信號量:信號量加一，這時超過限定的信號量數目會報錯ValueError: Semaphore released too many times    semaphore.release()    #***************高能結束******************for i in range(5):#建立5個線程    t=threading.Thread(target=run,args=(i,))    t.start()