34.python線程障礙對象Barrier-創(chuàng)新互聯(lián)

python線程Barrier俗稱障礙對象，也稱柵欄，也叫屏障。

成都創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括疏附網(wǎng)站建設(shè)、疏附網(wǎng)站制作、疏附網(wǎng)頁制作以及疏附網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，疏附網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到疏附省份的部分城市，未來相信會繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

一.線程障礙對象Barrier簡介

1 2 3 4 5

# 導(dǎo)入線程模塊 importthreading # 障礙對象barrier barrier=threading.Barrier(parties,action=None,timeout=None)

parties?—?線程計(jì)數(shù)器，記錄線程數(shù)量，也稱線程障礙數(shù)量；

action?—?是一個(gè)可調(diào)用函數(shù)，當(dāng)?shù)却木€程到達(dá)了線程障礙數(shù)量parties，其中一個(gè)線程會首先調(diào)用action?對應(yīng)函數(shù)，之后再執(zhí)行線程自己內(nèi)部的代碼；

timeout?—?默認(rèn)的超時(shí)時(shí)間；

二.線程障礙對象Barrier原理

與之前介紹 互斥鎖Lock/事件Event/定時(shí)器Timer等不同，多線程Barrier會設(shè)置一個(gè)線程障礙數(shù)量parties，如果等待的線程數(shù)量沒有達(dá)到障礙數(shù)量parties，所有線程會處于阻塞狀態(tài)，當(dāng)?shù)却木€程到達(dá)了這個(gè)數(shù)量就會喚醒所有的等待線程。

可能說的有點(diǎn)抽象，以播放器為例子：首先一個(gè)線程做播放器初始化工作(加載本地文件或者獲取播放地址)，然后一個(gè)線程獲取視頻畫面，一個(gè)線程獲取視頻聲音，只有當(dāng)初始化工作完畢，視頻畫面獲取完畢，視頻聲音獲取完畢，播放器才會開始播放，其中任意一個(gè)線程沒有完成，播放器會處于阻塞狀態(tài)直到三個(gè)任務(wù)都完成！

三.多線程障礙對象Barrier相關(guān)函數(shù)介紹

wait(timeout=None)?—?阻塞并嘗試通過障礙，如果等待的線程數(shù)量大于或者等于線程障礙數(shù)量parties，則表示障礙通過，執(zhí)行action?對應(yīng)函數(shù)并執(zhí)行線程內(nèi)部代碼，反之則繼續(xù)等待；

如果wait(timeout=None)?等待超時(shí)，障礙將進(jìn)入斷開狀態(tài)！如果在線程等待期間障礙斷開或重置，此方法會引發(fā)BrokenBarrierError錯誤，注意添加異常處理，演示代碼查看案例一；

reset()?—?重置線程障礙數(shù)量，返回默認(rèn)的空狀態(tài)，即當(dāng)前阻塞的線程重新來過，如果在線程等待期間障礙斷開或重置，此方法會引發(fā)BrokenBarrierError錯誤，注意添加異常處理，演示代碼查看案例二；

四.線程障礙對象Barrier使用

1.案例一：常規(guī)使用

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46

# !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:何以解憂 @Blog(個(gè)人博客地址): shuopython.com @WeChat Official Account(微信公眾號)：猿說python @Github:www.github.com @File:python_arbrier.py @Time:2019/10/31 21:25 @Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅(jiān)持不懈地積累！ """ # 導(dǎo)入線程模塊 importthreading defplyer_display(): print('初始化通過完成，音視頻同步完成，可以開始播放....') # 設(shè)置3個(gè)障礙對象 barrier=threading.Barrier(3,action=plyer_display,timeout=None) defplayer_init(statu): print(statu) try: # 設(shè)置超時(shí)時(shí)間，如果2秒內(nèi)，沒有達(dá)到障礙線程數(shù)量， # 會進(jìn)入斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤 barrier.wait(2) exceptExceptionase:# 斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤 print("等待超時(shí)了... ") else: print("xxxyyyyxxxxxyyyyxxxyyyy") if__name__=='__main__': statu_list=["init ready","video ready","audio ready"] thread_list=list() foriinrange(0,3): t=threading.Thread(target=player_init,args=(statu_list[i],)) t.start() thread_list.append(t) fortinthread_list: t.join()

輸出結(jié)果：

1 2 3 4 5 6 7

initready videoready audioready 初始化通過完成，音視頻同步完成，可以開始播放.... xxxyyyyxxxxxyyyyxxxyyyy xxxyyyyxxxxxyyyyxxxyyyy xxxyyyyxxxxxyyyyxxxyyyy

注意：如果barrier.wait(timeout=None)等待超時(shí)，會進(jìn)入斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤，為了程序的健壯性，最好加上異常處理；

2.案例二：重置線程障礙數(shù)量reset()

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41

# 導(dǎo)入線程模塊 importthreading defplyer_display(): print('初始化通過完成，音視頻同步完成，可以開始播放....') # 設(shè)置3個(gè)障礙對象 barrier=threading.Barrier(3,action=plyer_display,timeout=None) defplayer_init(statu): whileTrue: print(statu) try: # 設(shè)置超時(shí)時(shí)間，如果2秒內(nèi)，沒有達(dá)到障礙線程數(shù)量， # 會進(jìn)入斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤 barrier.wait(2) exceptExceptionase:# 斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤 # print("斷開狀態(tài)... ") continue else: print("xxxyyyxxxyyyxxxyyy") break if__name__=='__main__': statu_list=["init ready","video ready","audio ready"] thread_list=list() foriinrange(0,3): t=threading.Thread(target=player_init,args=(statu_list[i],)) t.start() thread_list.append(t) ifi==1:# 重置狀態(tài) print("動作片....") barrier.reset() fortinthread_list: t.join()

輸出結(jié)果：

1 2 3 4 5 6 7 8 9 10

initready videoready 動作片.... initready videoready audioready 初始化通過完成，音視頻同步完成，可以開始播放.... xxxyyyxxxyyyxxxyyy xxxyyyxxxyyyxxxyyy xxxyyyxxxyyyxxxyyy

注意：如果barrier.wait(timeout=None)等待超時(shí)，會進(jìn)入斷開狀態(tài)，引發(fā)BrokenBarrierError錯誤，為了程序的健壯性，最好加上異常處理；

猜你喜歡:

1.python多線程創(chuàng)建和參數(shù)傳遞

2.python多線程條件變量Condition

3.python多線程互斥鎖Lock

4.python多線程事件Event

5.python多線程定時(shí)器Timer

轉(zhuǎn)載請注明：猿說Python???python線程障礙對象Barrier

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.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)用場景需求。

網(wǎng)頁題目：34.python線程障礙對象Barrier-創(chuàng)新互聯(lián)
URL地址：http://bm7419.com/article18/cesdgp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供標(biāo)簽優(yōu)化、企業(yè)網(wǎng)站制作、微信小程序、響應(yīng)式網(wǎng)站、網(wǎng)站改版、網(wǎng)站排名

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)