From 2fa4cc55e9e5fdf1817d5ff1d82a23eb12b69e40 Mon Sep 17 00:00:00 2001 From: Georg Brandl Date: Thu, 28 Oct 2010 13:01:06 +0000 Subject: Support new Condition return value in the multiprocessing version. --- Lib/multiprocessing/synchronize.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/Lib/multiprocessing/synchronize.py b/Lib/multiprocessing/synchronize.py index 7f4718c..edf6c3e 100644 --- a/Lib/multiprocessing/synchronize.py +++ b/Lib/multiprocessing/synchronize.py @@ -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' -- cgit v0.12