Searched refs:parties (Results 1 - 8 of 8) sorted by relevance
| /third_party/python/Lib/asyncio/ |
| H A D | locks.py | 455 def __init__(self, parties):
456 """Create a barrier, initialised to 'parties' tasks."""
457 if parties < 1:
458 raise ValueError('parties must be > 0')
462 self._parties = parties
470 extra += f', waiters:{self.n_waiting}/{self.parties}'
474 # wait for the barrier reaches the parties number
486 Returns an unique and individual index number from 0 to 'parties-1'.
573 def parties(self): member in Barrier
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | context.py | 95 def Barrier(self, parties, action=None, timeout=None):
98 return Barrier(parties, action, timeout, ctx=self.get_context())
|
| H A D | synchronize.py | 365 def __init__(self, parties, action=None, timeout=None, *, ctx):
370 self.__setstate__((parties, action, timeout, cond, wrapper))
|
| H A D | managers.py | 1109 def parties(self): member in BarrierProxy
1110 return self._callmethod('__getattribute__', ('parties',))
|
| /third_party/python/Lib/ |
| H A D | threading.py | 646 def __init__(self, parties, action=None, timeout=None):
647 """Create a barrier, initialised to 'parties' threads.
658 self._parties = parties
667 f" waiters={self.n_waiting}/{self.parties}>")
675 Returns an individual index number from 0 to 'parties-1'.
774 # a broken state all parties awakened.
779 def parties(self): member in Barrier
|
| /third_party/python/Lib/test/ |
| H A D | lock_tests.py | 859 m = self.barrier.parties
|
| H A D | _test_multiprocessing.py | 1844 m = barrier.parties
2012 self.assertEqual(len(results), self.barrier.parties)
2032 self.assertEqual(len(results), barrier.parties)
5667 assert obj.parties == 5
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_locks.py | 1094 for i in range(barrier.parties - barrier.n_waiting):
1347 # N-1 tasks waiting on barrier with N parties
1479 # wit here to reach the `parties`
|
Completed in 17 milliseconds