Searched refs:QueueBarrier (Results 1 – 2 of 2) sorted by relevance
52 # Create the shared QueueBarrier to synchronize the processes.53 barrier = queue_barrier.QueueBarrier(len(machines)-1)
12 class QueueBarrier(object): class