Lines Matching defs:tasks
11 from . import tasks
450 Useful for synchronizing a fixed number of tasks at known synchronization
456 """Create a barrier, initialised to 'parties' tasks."""
460 self._cond = Condition() # notify all tasks when state changes
464 self._count = 0 # count tasks in Barrier
484 When the specified number of tasks have started waiting, they are all
501 # Wake up any tasks waiting for barrier to drain.
521 # Release the tasks waiting in the barrier.
524 # Next waiting tasks will be blocked until the end of draining.
540 # If we are the last tasks to exit the barrier, signal any tasks
550 Any tasks currently waiting will get the BrokenBarrier exception
556 #reset the barrier, waking up tasks
565 Useful in case of error. Any currently waiting tasks and tasks
574 """Return the number of tasks required to trip the barrier."""
579 """Return the number of tasks currently waiting at the barrier."""