| /third_party/python/Lib/multiprocessing/ |
| D | context.py | 85 def BoundedSemaphore(self, value=1): member in BaseContext
87 from .synchronize import BoundedSemaphore
88 return BoundedSemaphore(value, ctx=self.get_context())
|
| D | queues.py | 49 self._sem = ctx.BoundedSemaphore(maxsize)
|
| D | synchronize.py | 142 class BoundedSemaphore(Semaphore): class
|
| D | managers.py | 1213 SyncManager.register('BoundedSemaphore', threading.BoundedSemaphore,
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_pep492.py | 50 asyncio.BoundedSemaphore(),
72 asyncio.BoundedSemaphore(),
|
| D | test_locks.py | 55 asyncio.BoundedSemaphore,
73 asyncio.BoundedSemaphore(),
924 sem = asyncio.BoundedSemaphore()
|
| /third_party/python/Doc/library/ |
| D | asyncio-sync.rst | 30 * :class:`BoundedSemaphore`
337 Unlike :class:`BoundedSemaphore`, :class:`Semaphore` allows
341 BoundedSemaphore chapter
344 .. class:: BoundedSemaphore(value=1)
|
| D | asyncio-api-index.rst | 186 * - :class:`BoundedSemaphore`
|
| D | threading.rst | 855 .. class:: BoundedSemaphore(value=1)
879 pool_sema = BoundedSemaphore(value=maxconnections)
1120 :class:`Semaphore`, and :class:`BoundedSemaphore` objects may be used as
|
| D | multiprocessing.rst | 341 :class:`RLock`, :class:`Semaphore`, :class:`BoundedSemaphore`,
1235 .. class:: BoundedSemaphore([value])
1238 :class:`threading.BoundedSemaphore`.
1389 blocked by a call to :meth:`BoundedSemaphore.acquire`, :meth:`Lock.acquire`,
1775 .. method:: BoundedSemaphore([value])
1777 Create a shared :class:`threading.BoundedSemaphore` object and return a
|
| /third_party/python/Lib/multiprocessing/dummy/ |
| D | __init__.py | 26 from threading import Lock, RLock, Semaphore, BoundedSemaphore
|
| /third_party/python/Lib/asyncio/ |
| D | locks.py | 404 class BoundedSemaphore(Semaphore): class
|
| /third_party/python/Lib/test/ |
| D | test_threading.py | 140 sema = threading.BoundedSemaphore(value=3)
777 bs = threading.BoundedSemaphore(limit)
1583 semtype = staticmethod(threading.BoundedSemaphore)
|
| D | _test_multiprocessing.py | 1280 sem = self.BoundedSemaphore(2)
5746 BoundedSemaphore = staticmethod(multiprocessing.BoundedSemaphore) variable in ProcessesMixin
5764 BoundedSemaphore = property(operator.attrgetter('manager.BoundedSemaphore')) variable in ManagerMixin
5830 BoundedSemaphore = staticmethod(multiprocessing.dummy.BoundedSemaphore) variable in ThreadsMixin
|
| D | test_contextlib.py | 376 lock = threading.BoundedSemaphore()
|
| /third_party/python/Lib/ |
| D | threading.py | 486 class BoundedSemaphore(Semaphore): class
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.5.0b1.rst | 675 asyncio.Lock, Condition, Semaphore, and BoundedSemaphore support new 'async
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.8.rst | 1686 :class:`asyncio.BoundedSemaphore`, :class:`asyncio.Queue`,
|
| D | 3.3.rst | 2037 :class:`threading.BoundedSemaphore`, :class:`threading.Event`, and
|
| /third_party/python/Misc/ |
| D | HISTORY | 3812 - Issue #19158: A rare race in BoundedSemaphore could allow .release() too
18517 Lock, RLock, Condition, Semaphore, BoundedSemaphore.
24538 - Added function threading.BoundedSemaphore()
|