##線程鎖應(yīng)用
import time,threading
python中自己加鎖了所以用不著!
def run(n):
lock.acquire() #獲取一把鎖
global num
num+=1
lock.release() #釋放鎖
lock=threading.Lock()
num=0
loot=[] #創(chuàng)建一個(gè)空列表(存線程實(shí)例)
for i in range (50):
t=threading.Thread(target=run,args=("t-%s"%i,))
t.start()
loot.append(t) #為了不阻塞后面的線程啟動(dòng),不在這里join,先放到一個(gè)列表里
for t in loot:#循環(huán)線程實(shí)例列表,等待所有線程執(zhí)行完畢
t.join() #等待一個(gè)線程全部執(zhí)行完再執(zhí)行其他線程(把并程改成了串行)
print("-----ddddd-----",threading.current_thread(),threading.active_count())#看是否是主線程,活躍的線程數(shù)量
print("num:",num)
##遞歸鎖的意思是相當(dāng)于已過字典。。。每開一道門就存門對(duì)應(yīng)的鑰匙數(shù)據(jù),退出時(shí)去字典找對(duì)應(yīng)的門用的鑰匙
def run1():
print("grab the first part data")
lock.acquire()
global num
num+=1
lock.release()
return num
def run2():
print("grab the second part data")
lock.acquire()
global num2
num2+=1
lock.release()
return num2
def run3():
lock.acquire()
res=run1()
print("----between run1 and run2-----")
res2=run2()
lock.release()
print(res,res2)
num,num2=0,0
lock=threading.RLock() ##遞歸鎖創(chuàng)建
for i in range(10):
t=threading.Thread(target=run3)
t.start()
while threading.active_count()!=1:
print(threading.active_count())
else:
print("------all threads done------")
print(num,num2)
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時(shí)售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。