您好,登錄后才能下訂單哦!
##線程鎖應(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)于已過(guò)字典。。。每開一道門就存門對(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)
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。