34.python 線程障礙對象Barrier

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

 

一.線程障礙對象Barrier簡介

 

1 2 3 4 5

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

parties — 線程計數器，記錄線程數量，也稱線程障礙數量；

action — 是一個可調用函數，當等待的線程到達了線程障礙數量parties，其中一個線程會首先調用action 對應函數，以後再執行線程本身內部的代碼；

timeout — 默認的超時時間；

二.線程障礙對象Barrier原理

與以前介紹 互斥鎖Lock/事件Event/定時器Timer等不一樣，多線程Barrier會設置一個線程障礙數量parties，若是等待的線程數量沒有達到障礙數量parties，全部線程會處於阻塞狀態，當等待的線程到達了這個數量就會喚醒全部的等待線程。

 

可能說的有點抽象，以播放器爲例子：首先一個線程作播放器初始化工做(加載本地文件或者獲取播放地址)，而後一個線程獲取視頻畫面，一個線程獲取視頻聲音，只有當初始化工做完畢，視頻畫面獲取完畢，視頻聲音獲取完畢，播放器纔會開始播放，其中任意一個線程沒有完成，播放器會處於阻塞狀態直到三個任務都完成！

 

 

三.多線程障礙對象Barrier相關函數介紹

wait(timeout=None) — 阻塞並嘗試經過障礙，若是等待的線程數量大於或者等於線程障礙數量parties，則表示障礙經過，執行action 對應函數並執行線程內部代碼，反之則繼續等待；

若是wait(timeout=None) 等待超時，障礙將進入斷開狀態！若是在線程等待期間障礙斷開或重置，此方法會引起BrokenBarrierError錯誤，注意添加異常處理，演示代碼查看案例一；

 

reset() — 重置線程障礙數量，返回默認的空狀態，即當前阻塞的線程從新來過，若是在線程等待期間障礙斷開或重置，此方法會引起BrokenBarrierError錯誤，注意添加異常處理，演示代碼查看案例二；

 

四.線程障礙對象Barrier使用

1.案例一：常規使用

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(我的博客地址): shuopython.com @WeChat Official Account(微信公衆號)：猿說python @Github:www.github.com   @File:python_arbrier.py @Time:2019/10/31 21:25   @Motto:不積跬步無以致千里，不積小流無以成江海，程序人生的精彩須要堅持不懈地積累！ """   # 導入線程模塊 import threading   def plyer_display():     print('初始化經過完成，音視頻同步完成，能夠開始播放....')   # 設置3個障礙對象 barrier = threading.Barrier(3, action=plyer_display, timeout=None)     def player_init(statu):     print(statu)     try:         # 設置超時時間，若是2秒內，沒有達到障礙線程數量，         # 會進入斷開狀態，引起BrokenBarrierError錯誤         barrier.wait(2)     except Exception as e: # 斷開狀態，引起BrokenBarrierError錯誤         print("等待超時了... ")     else:         print("xxxyyyyxxxxxyyyyxxxyyyy")   if __name__ == '__main__':          statu_list = ["init ready","video ready","audio ready"]     thread_list = list()     for i in range(0,3):         t = threading.Thread(target=player_init,args=(statu_list[i],))         t.start()         thread_list.append(t)       for t in thread_list:         t.join()

輸出結果：

1 2 3 4 5 6 7

init ready video ready audio ready 初始化經過完成，音視頻同步完成，能夠開始播放.... xxxyyyyxxxxxyyyyxxxyyyy xxxyyyyxxxxxyyyyxxxyyyy xxxyyyyxxxxxyyyyxxxyyyy

注意：若是barrier.wait(timeout=None)等待超時，會進入斷開狀態，引起BrokenBarrierError錯誤，爲了程序的健壯性，最好加上異常處理；

 

2.案例二：重置線程障礙數量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

# 導入線程模塊 import threading   def plyer_display():     print('初始化經過完成，音視頻同步完成，能夠開始播放....')   # 設置3個障礙對象 barrier = threading.Barrier(3, action=plyer_display, timeout=None)     def player_init(statu):       while True:         print(statu)         try:             # 設置超時時間，若是2秒內，沒有達到障礙線程數量，             # 會進入斷開狀態，引起BrokenBarrierError錯誤             barrier.wait(2)         except Exception as e: # 斷開狀態，引起BrokenBarrierError錯誤             # print("斷開狀態... ")             continue         else:             print("xxxyyyxxxyyyxxxyyy")             break   if __name__ == '__main__':       statu_list = ["init ready","video ready","audio ready"]     thread_list = list()     for i in range(0,3):         t = threading.Thread(target=player_init,args=(statu_list[i],))         t.start()                  thread_list.append(t)         if i == 1: # 重置狀態             print("動做片....")             barrier.reset()         for t in thread_list:         t.join()

輸出結果：

1 2 3 4 5 6 7 8 9 10

init ready video ready 動做片.... init ready video ready audio ready 初始化經過完成，音視頻同步完成，能夠開始播放.... xxxyyyxxxyyyxxxyyy xxxyyyxxxyyyxxxyyy xxxyyyxxxyyyxxxyyy

注意：若是barrier.wait(timeout=None)等待超時，會進入斷開狀態，引起BrokenBarrierError錯誤，爲了程序的健壯性，最好加上異常處理；

 

猜你喜歡:

1.python多線程建立和參數傳遞

2.python多線程條件變量Condition

3.python多線程互斥鎖Lock

4.python多線程事件Event

5.python多線程定時器Timer

 

轉載請註明：猿說Python » python線程障礙對象Barrier