Place the barrier into a 'broken' state. Useful in case of error. Any currently waiting tasks and tasks attempting to 'wait()' will have BrokenBarrierError raised.
(self)
| 560 | self._cond.notify_all() |
| 561 | |
| 562 | async def abort(self): |
| 563 | """Place the barrier into a 'broken' state. |
| 564 | |
| 565 | Useful in case of error. Any currently waiting tasks and tasks |
| 566 | attempting to 'wait()' will have BrokenBarrierError raised. |
| 567 | """ |
| 568 | async with self._cond: |
| 569 | self._state = _BarrierState.BROKEN |
| 570 | self._cond.notify_all() |
| 571 | |
| 572 | @property |
| 573 | def parties(self): |
no test coverage detected