Pythonのバリアオブジェクト

バリアは、単一または複数のスレッドが一連のアクティビティのポイントまで待機し、一緒に進行するPython同期手法の1つを提供します。

バリアオブジェクトを定義するには、「スレッド化。バリア」を使用しています。

threading.Barrier(parties, action = None, timeout = None)

どこで、

• パーティ=スレッド数

• action=リリース時にスレッドの1つによって呼び出されます。

• タイムアウト=デフォルトのタイムアウト値。 wait（）にタイムアウト値が指定されていない場合は、このタイムアウト値が使用されます。

下記のメソッドはバリアクラスで使用されます。

BarrierThread.py

from random import randrange
from threading import Barrier, Thread
from time import ctime, sleep
num = 4
# 4 threads will need to pass this barrier to get released.
b = Barrier(num)
names = ['India', 'Japan', 'USA', 'China']
def player():
   name = names.pop()
   sleep(randrange(2, 5))
   print('%s reached the barrier at: %s \n' % (name, ctime()))
   b.wait()
threads = []
print("Race starts now…")
for i in range(num):
   threads.append(Thread(target=player))
   threads[-1].start()
"""
Below loop enables waiting for the threads to complete before moving on with the main script.
"""
for thread in threads:
   thread.join()
print("All Reached Barrier Point!")

結果

Race starts now…
India reached the barrier at: Fri Jan 18 14:07:44 2019
China reached the barrier at: Fri Jan 18 14:07:44 2019
Japan reached the barrier at: Fri Jan 18 14:07:46 2019
USA reached the barrier at: Fri Jan 18 14:07:46 2019
All Reached Barrier Point!