mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-10-07 07:31:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 13

Issue #850728: Add a *timeout* parameter to the acquire() method of

Browse source 
`threading.Semaphore` objects.  Original patch by Torsten Landschoff.
This commit is contained in:
Antoine Pitrou 2010-04-17 23:51:58 +00:00
parent 2d9cb9c1cb
commit 0454af9b54
5 changed files with 40 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

14
Lib/threading.py
View file

@ -290,8 +290,11 @@ class _Semaphore(_Verbose):
self._cond = Condition(Lock())
self._value = value
def acquire(self, blocking=True):
def acquire(self, blocking=True, timeout=None):
if not blocking and timeout is not None:
raise ValueError("can't specify timeout for non-blocking acquire")
rc = False
endtime = None
self._cond.acquire()
while self._value == 0:
if not blocking:
@ -299,7 +302,14 @@ class _Semaphore(_Verbose):
if __debug__:
self._note("%s.acquire(%s): blocked waiting, value=%s",
self, blocking, self._value)
self._cond.wait()
if timeout is not None:
if endtime is None:
endtime = _time() + timeout
else:
timeout = endtime - _time()
if timeout <= 0:
break
self._cond.wait(timeout)
else:
self._value = self._value - 1
if __debug__: