目錄

• 一.Python 線程障礙對象 Barrier 簡介
• 二.Python 線程障礙對象 Barrier 原理
• 三.Python 線程障礙對象 Barrier 函數介紹
• 四.Python 線程障礙對象 Barrier 使用
  • 1.案例一：常規使用
  • 2.案例二：重置線程障礙數量 reset
• 五.猜你喜歡

零基礎 Python 學習路線推薦 : Python 學習目錄 >> Python 基礎入門

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

一.Python 線程障礙對象 Barrier 簡介

# 導入線程模塊 import threading''' 參數介紹：parties — 線程計數器，記錄線程數量，也稱線程障礙數量；action — 是一個可調用函數，當等待的線程到達了線程障礙數量parties，其中一個線程會首先調用action 對應函數，之后再執行線程自己內部的代碼；timeout — 默認的超時時間； '''# 障礙對象barrier barrier = threading.Barrier(parties, action=None, timeout=None)

二.Python 線程障礙對象 Barrier 原理

與之前介紹 互斥鎖 Lock / 事件 Event / 定時器 Timer 等不同，多線程 Barrier 會設置一個線程障礙數量 parties ，如果等待的線程數量沒有達到障礙數量 parties ，所有線程會處于阻塞狀態，當等待的線程到達了這個數量就會喚醒所有的等待線程。

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

三.Python 線程障礙對象 Barrier 函數介紹

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

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

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

四.Python 線程障礙對象 Barrier 使用

1.案例一：常規使用

# !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:猿說編程 @Blog(個人博客地址): www.codersrc.com @File:Python 線程障礙對象 Barrier.py @Time:2021/05/04 07:37 @Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅持不懈地積累！"""# 導入線程模塊 import threadingdef 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("xxxooooxxxxxooooxxxoooo")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()''' 輸出結果：init ready video ready audio ready 初始化通過完成，音視頻同步完成，可以開始播放.... xxxooooxxxxxooooxxxoooo xxxooooxxxxxooooxxxoooo xxxooooxxxxxooooxxxoooo'''

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

2.案例二：重置線程障礙數量 reset

# !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:猿說編程 @Blog(個人博客地址): www.codersrc.com @File:Python 線程障礙對象 Barrier.py @Time:2021/05/04 07:37 @Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅持不懈地積累！"""# 導入線程模塊 import threadingdef 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("斷開狀態... ")continueelse:print("xxxooyyyxxxooyyyxxxooyyy")breakif __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()''' 輸出結果：init ready video ready 不想看愛情片，我要看愛情動作片.... init ready video ready audio ready 初始化通過完成，音視頻同步完成，可以開始播放.... xxxooyyyxxxooyyyxxxooyyy xxxooyyyxxxooyyyxxxooyyy xxxooyyyxxxooyyyxxxooyyy'''

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

五.猜你喜歡

Python 條件推導式

Python 列表推導式

Python 字典推導式

Python 不定長參數 *argc/**kargcs

Python 匿名函數 lambda

Python return 邏輯判斷表達式

Python is 和 == 區別

Python 可變數據類型和不可變數據類型

Python 淺拷貝和深拷貝

Python 異常處理

Python 線程創建和傳參

Python 線程互斥鎖 Lock

Python 線程時間 Event

Python 線程條件變量 Condition

Python 線程定時器 Timer

Python 線程信號量 Semaphore

Python 線程障礙對象 Barrier

Python 線程隊列 Queue – FIFO

Python 線程隊列 LifoQueue – LIFO

Python 線程優先隊列 PriorityQueue

Python 線程池 ThreadPoolExecutor(一)

Python 線程池 ThreadPoolExecutor(二)

Python 進程 Process 模塊

Python 進程 Process 與線程 threading 區別

Python 進程間通信 Queue / Pipe

Python 進程池 multiprocessing.Pool

Python GIL 鎖

未經允許不得轉載：猿說編程 ? Python 線程障礙對象 Barrier

總結

以上是生活随笔為你收集整理的Python 线程障碍对象 Barrier - Python零基础入门教程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。