| /external/python/cpython3/Lib/multiprocessing/ |
| context.py | 94 def Barrier(self, parties, action=None, timeout=None):
97 return Barrier(parties, action, timeout, ctx=self.get_context())
|
| synchronize.py | 362 def __init__(self, parties, action=None, timeout=None, *, ctx):
367 self.__setstate__((parties, action, timeout, cond, wrapper))
|
| managers.py | 1083 def parties(self): member in class:BarrierProxy
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JSR166TestCase.java | [all...] |
| /external/python/cpython3/Lib/ |
| threading.py | 576 def __init__(self, parties, action=None, timeout=None):
577 """Create a barrier, initialised to 'parties' threads.
588 self._parties = parties
598 Returns an individual index number from 0 to 'parties-1'.
697 # a broken state all parties awakened.
702 def parties(self): member in class:Barrier
[all...] |
| /external/python/cpython3/Lib/test/ |
| lock_tests.py | 777 m = self.barrier.parties
|
| _test_multiprocessing.py | [all...] |
| /external/kotlinc/ |
| LICENSE | [all...] |
| NOTICE | [all...] |
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| server.go | 422 // here. It also says both parties must support at least
[all...] |
