(self, timeout)
| 772 | # Wait in the barrier until we are released. Raise an exception |
| 773 | # if the barrier is reset or broken. |
| 774 | def _wait(self, timeout): |
| 775 | if not self._cond.wait_for(lambda : self._state != 0, timeout): |
| 776 | #timed out. Break the barrier |
| 777 | self._break() |
| 778 | raise BrokenBarrierError |
| 779 | if self._state < 0: |
| 780 | raise BrokenBarrierError |
| 781 | assert self._state == 1 |
| 782 | |
| 783 | # If we are the last thread to exit the barrier, signal any threads |
| 784 | # waiting for the barrier to drain. |