(self, parties, action=None, timeout=None, *, ctx)
| 377 | class Barrier(threading.Barrier): |
| 378 | |
| 379 | def __init__(self, parties, action=None, timeout=None, *, ctx): |
| 380 | import struct |
| 381 | from .heap import BufferWrapper |
| 382 | wrapper = BufferWrapper(struct.calcsize('i') * 2) |
| 383 | cond = ctx.Condition() |
| 384 | self.__setstate__((parties, action, timeout, cond, wrapper)) |
| 385 | self._state = 0 |
| 386 | self._count = 0 |
| 387 | |
| 388 | def __setstate__(self, state): |
| 389 | (self._parties, self._action, self._timeout, |
nothing calls this directly
no test coverage detected