| /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
|
| D | managers.py | 1105 SyncManager.register('BoundedSemaphore', threading.BoundedSemaphore,
|
| /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 | 143 class BoundedSemaphore(Semaphore): class
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-sync.rst | 16 * :class:`BoundedSemaphore`
21 :class:`~threading.BoundedSemaphore`), but it has no *timeout* parameter. The
285 BoundedSemaphore section in Semaphores
288 .. class:: BoundedSemaphore(value=1, \*, loop=None)
|
| D | threading.rst | 731 .. class:: BoundedSemaphore(value=1)
755 pool_sema = BoundedSemaphore(value=maxconnections)
994 :class:`Semaphore`, and :class:`BoundedSemaphore` objects may be used as
|
| D | multiprocessing.rst | 323 :class:`RLock`, :class:`Semaphore`, :class:`BoundedSemaphore`,
1159 .. class:: BoundedSemaphore([value])
1162 :class:`threading.BoundedSemaphore`.
1313 blocked by a call to :meth:`BoundedSemaphore.acquire`, :meth:`Lock.acquire`,
1699 .. method:: BoundedSemaphore([value])
1701 Create a shared :class:`threading.BoundedSemaphore` object and return a
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_pep492.py | 35 asyncio.BoundedSemaphore(loop=self.loop),
57 asyncio.BoundedSemaphore(loop=self.loop),
|
| /external/python/cpython3/Lib/test/ |
| D | test_dummy_threading.py | 39 sema = _threading.BoundedSemaphore(value=3)
|
| D | test_threading.py | 95 sema = threading.BoundedSemaphore(value=3)
606 bs = threading.BoundedSemaphore(limit)
1118 semtype = staticmethod(threading.BoundedSemaphore)
|
| D | _test_multiprocessing.py | 806 sem = self.BoundedSemaphore(2)
3892 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore) variable in ProcessesMixin
3910 BoundedSemaphore = property(operator.attrgetter('manager.BoundedSemaphore')) variable in ManagerMixin
3962 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore) variable in ThreadsMixin
|
| D | test_contextlib.py | 284 lock = threading.BoundedSemaphore()
|
| /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/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 | 464 class BoundedSemaphore(Semaphore): class
|
| /external/python/cpython3/Lib/ |
| D | threading.py | 449 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`,
936 .. class:: BoundedSemaphore([value])
939 :class:`threading.BoundedSemaphore`.
1087 The :meth:`acquire` method of :class:`BoundedSemaphore`, :class:`Lock`,
1101 blocked by a call to :meth:`BoundedSemaphore.acquire`, :meth:`Lock.acquire`,
1463 .. method:: BoundedSemaphore([value])
1465 Create a shared :class:`threading.BoundedSemaphore` object and return a
|
| /external/python/cpython2/Lib/ |
| D | threading.py | 497 def BoundedSemaphore(*args, **kwargs): function
|