Support new Condition return value in the multiprocessing version.
This commit is contained in:
parent
7362c4f311
commit
2fa4cc55e9
|
@ -217,7 +217,7 @@ class Condition(object):
|
|||
|
||||
try:
|
||||
# wait for notification or timeout
|
||||
self._wait_semaphore.acquire(True, timeout)
|
||||
ret = self._wait_semaphore.acquire(True, timeout)
|
||||
finally:
|
||||
# indicate that this thread has woken
|
||||
self._woken_count.release()
|
||||
|
@ -225,6 +225,7 @@ class Condition(object):
|
|||
# reacquire lock
|
||||
for i in range(count):
|
||||
self._lock.acquire()
|
||||
return ret
|
||||
|
||||
def notify(self):
|
||||
assert self._lock._semlock._is_mine(), 'lock is not owned'
|
||||
|
|
Loading…
Reference in New Issue