From 41eb85b194909d68bb05b81442f10026b9279560 Mon Sep 17 00:00:00 2001 From: Richard Oudkerk Date: Sun, 6 May 2012 16:45:02 +0100 Subject: Make AcquirerProxy.acquire() support timeout argument --- Lib/multiprocessing/managers.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/Lib/multiprocessing/managers.py b/Lib/multiprocessing/managers.py index dc8166a..36bcf8f 100644 --- a/Lib/multiprocessing/managers.py +++ b/Lib/multiprocessing/managers.py @@ -957,8 +957,9 @@ class IteratorProxy(BaseProxy): class AcquirerProxy(BaseProxy): _exposed_ = ('acquire', 'release') - def acquire(self, blocking=True): - return self._callmethod('acquire', (blocking,)) + def acquire(self, blocking=True, timeout=None): + args = (blocking,) if timeout is None else (blocking, timeout) + return self._callmethod('acquire', args) def release(self): return self._callmethod('release') def __enter__(self): -- cgit v0.12