(self, parties, action=None, timeout=None, *, ctx)
| 370 | class Barrier(threading.Barrier): |
| 371 | |
| 372 | def __init__(self, parties, action=None, timeout=None, *, ctx): |
| 373 | import struct |
| 374 | from .heap import BufferWrapper |
| 375 | wrapper = BufferWrapper(struct.calcsize('i') * 2) |
| 376 | cond = ctx.Condition() |
| 377 | self.__setstate__((parties, action, timeout, cond, wrapper)) |
| 378 | self._state = 0 |
| 379 | self._count = 0 |
| 380 | |
| 381 | def __setstate__(self, state): |
| 382 | (self._parties, self._action, self._timeout, |
nothing calls this directly
no test coverage detected