/external/python/cpython2/Lib/multiprocessing/ |
D | __init__.py | 199 def BoundedSemaphore(value=1): function 203 from multiprocessing.synchronize import BoundedSemaphore 204 return BoundedSemaphore(value)
|
D | queues.py | 48 from .synchronize import Lock, BoundedSemaphore, Semaphore, Condition 69 self._sem = BoundedSemaphore(maxsize)
|
D | synchronize.py | 127 class BoundedSemaphore(Semaphore): class
|
/external/python/cpython3/Lib/multiprocessing/ |
D | context.py | 84 def BoundedSemaphore(self, value=1): member in BaseContext 86 from .synchronize import BoundedSemaphore 87 return BoundedSemaphore(value, ctx=self.get_context())
|
D | queues.py | 48 self._sem = ctx.BoundedSemaphore(maxsize)
|
D | synchronize.py | 142 class BoundedSemaphore(Semaphore): class
|
/external/python/cpython3/Doc/library/ |
D | asyncio-sync.rst | 26 * :class:`BoundedSemaphore` 302 Unlike :class:`BoundedSemaphore`, :class:`Semaphore` allows 306 BoundedSemaphore chapter 309 .. class:: BoundedSemaphore(value=1, \*, loop=None)
|
D | asyncio-api-index.rst | 183 * - :class:`BoundedSemaphore`
|
D | threading.rst | 734 .. class:: BoundedSemaphore(value=1) 758 pool_sema = BoundedSemaphore(value=maxconnections) 997 :class:`Semaphore`, and :class:`BoundedSemaphore` objects may be used as
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_pep492.py | 47 asyncio.BoundedSemaphore(loop=self.loop), 69 asyncio.BoundedSemaphore(loop=self.loop),
|
D | test_locks.py | 75 asyncio.BoundedSemaphore(loop=loop), 997 sem = asyncio.BoundedSemaphore(loop=self.loop)
|
/external/python/cpython2/Lib/test/ |
D | test_dummy_threading.py | 39 sema = _threading.BoundedSemaphore(value=3)
|
D | test_threading.py | 86 sema = threading.BoundedSemaphore(value=3) 468 bs = threading.BoundedSemaphore(limit) 889 semtype = staticmethod(threading.BoundedSemaphore)
|
D | test_contextlib.py | 317 lock = threading.BoundedSemaphore()
|
/external/python/cpython3/Lib/test/ |
D | test_dummy_threading.py | 39 sema = _threading.BoundedSemaphore(value=3)
|
D | test_threading.py | 94 sema = threading.BoundedSemaphore(value=3) 645 bs = threading.BoundedSemaphore(limit) 1163 semtype = staticmethod(threading.BoundedSemaphore)
|
D | _test_multiprocessing.py | 1171 sem = self.BoundedSemaphore(2) 4863 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore) variable in ProcessesMixin 4881 BoundedSemaphore = property(operator.attrgetter('manager.BoundedSemaphore')) variable in ManagerMixin 4948 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore) variable in ThreadsMixin
|
/external/python/cpython3/Lib/multiprocessing/dummy/ |
D | __init__.py | 26 from threading import Lock, RLock, Semaphore, BoundedSemaphore
|
/external/python/cpython2/Lib/multiprocessing/dummy/ |
D | __init__.py | 53 from threading import Lock, RLock, Semaphore, BoundedSemaphore
|
/external/python/cpython3/Lib/asyncio/ |
D | locks.py | 493 class BoundedSemaphore(Semaphore): class
|
/external/python/cpython3/Lib/ |
D | threading.py | 450 class BoundedSemaphore(Semaphore): class
|
/external/python/cpython2/Doc/library/ |
D | threading.rst | 144 .. function:: BoundedSemaphore([value]) 690 pool_sema = BoundedSemaphore(value=maxconnections) 806 :class:`Semaphore`, and :class:`BoundedSemaphore` objects may be used as
|
D | multiprocessing.rst | 219 :class:`Semaphore`, :class:`BoundedSemaphore`, :class:`Condition`, 941 .. class:: BoundedSemaphore([value]) 944 :class:`threading.BoundedSemaphore`. 1092 The :meth:`acquire` method of :class:`BoundedSemaphore`, :class:`Lock`, 1106 blocked by a call to :meth:`BoundedSemaphore.acquire`, :meth:`Lock.acquire`, 1468 .. method:: BoundedSemaphore([value]) 1470 Create a shared :class:`threading.BoundedSemaphore` object and return a
|
/external/python/cpython2/Lib/ |
D | threading.py | 497 def BoundedSemaphore(*args, **kwargs): function
|
/external/python/cpython3/Misc/NEWS.d/ |
D | 3.5.0b1.rst | 675 asyncio.Lock, Condition, Semaphore, and BoundedSemaphore support new 'async
|