Home
last modified time | relevance | path

Searched refs:BoundedSemaphore (Results 1 – 25 of 34) sorted by relevance

12

/external/python/cpython2/Lib/multiprocessing/
D__init__.py199 def BoundedSemaphore(value=1): function
203 from multiprocessing.synchronize import BoundedSemaphore
204 return BoundedSemaphore(value)
Dqueues.py48 from .synchronize import Lock, BoundedSemaphore, Semaphore, Condition
69 self._sem = BoundedSemaphore(maxsize)
Dsynchronize.py127 class BoundedSemaphore(Semaphore): class
/external/python/cpython3/Lib/multiprocessing/
Dcontext.py84 def BoundedSemaphore(self, value=1): member in BaseContext
86 from .synchronize import BoundedSemaphore
87 return BoundedSemaphore(value, ctx=self.get_context())
Dqueues.py48 self._sem = ctx.BoundedSemaphore(maxsize)
Dsynchronize.py142 class BoundedSemaphore(Semaphore): class
/external/python/cpython3/Doc/library/
Dasyncio-sync.rst26 * :class:`BoundedSemaphore`
302 Unlike :class:`BoundedSemaphore`, :class:`Semaphore` allows
306 BoundedSemaphore chapter
309 .. class:: BoundedSemaphore(value=1, \*, loop=None)
Dasyncio-api-index.rst183 * - :class:`BoundedSemaphore`
Dthreading.rst734 .. 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/
Dtest_pep492.py47 asyncio.BoundedSemaphore(loop=self.loop),
69 asyncio.BoundedSemaphore(loop=self.loop),
Dtest_locks.py75 asyncio.BoundedSemaphore(loop=loop),
997 sem = asyncio.BoundedSemaphore(loop=self.loop)
/external/python/cpython2/Lib/test/
Dtest_dummy_threading.py39 sema = _threading.BoundedSemaphore(value=3)
Dtest_threading.py86 sema = threading.BoundedSemaphore(value=3)
468 bs = threading.BoundedSemaphore(limit)
889 semtype = staticmethod(threading.BoundedSemaphore)
Dtest_contextlib.py317 lock = threading.BoundedSemaphore()
/external/python/cpython3/Lib/test/
Dtest_dummy_threading.py39 sema = _threading.BoundedSemaphore(value=3)
Dtest_threading.py94 sema = threading.BoundedSemaphore(value=3)
645 bs = threading.BoundedSemaphore(limit)
1163 semtype = staticmethod(threading.BoundedSemaphore)
D_test_multiprocessing.py1171 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__.py26 from threading import Lock, RLock, Semaphore, BoundedSemaphore
/external/python/cpython2/Lib/multiprocessing/dummy/
D__init__.py53 from threading import Lock, RLock, Semaphore, BoundedSemaphore
/external/python/cpython3/Lib/asyncio/
Dlocks.py493 class BoundedSemaphore(Semaphore): class
/external/python/cpython3/Lib/
Dthreading.py450 class BoundedSemaphore(Semaphore): class
/external/python/cpython2/Doc/library/
Dthreading.rst144 .. function:: BoundedSemaphore([value])
690 pool_sema = BoundedSemaphore(value=maxconnections)
806 :class:`Semaphore`, and :class:`BoundedSemaphore` objects may be used as
Dmultiprocessing.rst219 :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/
Dthreading.py497 def BoundedSemaphore(*args, **kwargs): function
/external/python/cpython3/Misc/NEWS.d/
D3.5.0b1.rst675 asyncio.Lock, Condition, Semaphore, and BoundedSemaphore support new 'async

12