這篇文章將為大家詳細講解有關(guān)Mutes鎖中遞歸鎖及semaphore的示例分析,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個參考,希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站制作、網(wǎng)站設(shè)計和雅安機房托管的網(wǎng)絡(luò)公司,有著豐富的建站經(jīng)驗和案例。
#!-*-coding:utf-8-*-
#加用戶態(tài)的鎖,與全局解釋器鎖不一樣(GIL)
importthreading, time
defrun(n):
lock.acquire() #獲取用戶態(tài)鎖 也叫互斥鎖Mutex
globalnum #操作
#time.sleep(0.1) #加了sleep之后程序變串行的了 一般不要加
num +=1
lock.release() #釋放用戶態(tài)鎖
lock=threading.Lock()
num=0
t_objs = []
fori inrange(1000):
t = threading.Thread(target=run, args=("t %s"% i,))
t.start()
t_objs.append(t) # 把每個線程實例都加進來 不阻塞后面線程的啟動
fort int_objs: #取列表里的每個線程
t.join() #等待并行的每個線程全都執(zhí)行完畢 在往下走
print("----all threads has finished...",threading.current_thread(),threading.active_count())
print("num",num)
threading, time run1(): print() lock.acquire() num num += 1 lock.release() num run2(): print() lock.acquire() num2 num2 += 1 lock.release() num2 run3(): lock.acquire() res = run1() print() res2 = run2() lock.release() print(res, res2) num, num2 = 0, 0 lock = threading.RLock() i range(1): t = threading.Thread(target=run3) t.start() threading.active_count() != 1: print(threading.active_count()) : print() print(num, num2)
threading,time run(n): semaphore.acquire() time.sleep(1) print(%n) semaphore.release() __name__==: semaphore=threading.BoundedSemaphore(5) i range(20): t=threading.Thread(target=run,args=(i,)) t.start() threading.active_count() !=1: : print()
關(guān)于Mutes鎖中遞歸鎖及semaphore的示例分析就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,可以學(xué)到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
當(dāng)前文章:Mutes鎖中遞歸鎖及semaphore的示例分析
文章URL:http://chinadenli.net/article16/ppcpdg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供搜索引擎優(yōu)化、外貿(mào)網(wǎng)站建設(shè)、電子商務(wù)、Google、企業(yè)建站、域名注冊
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)