每一条线程调用 wait() 方法后表明自己已就位并进入阻塞状态,当所有的线程都调用了 wait() 方法时,他们将同时被释放。
创建一个可容纳 parties 条线程的 barrier。action 参数是一个在全部线程被释放时可被其中一条线程调用的可调用对象。timeout 参数是给 wait() 方法准备的,如果线程调用 wait() 方法时没有显式设定 timeout,那么这里的 timeout 将作为默认值被使用
class threading.Barrier(parties,action=None,timeout=None)
对象方法属性 | 描述 |
---|---|
wait(timeout=None) |
reset()|
abort()|将 barrier 置为 broken 状态。
parites|将要使用本 barrier 的线程的数量
n_waiting|正在等待本 barrier 的线程的数量
broken|布尔值。如果本 barrier 为 broken 状态,则为 True
参考:
https://my.oschina.net/lionets/blog/194577