Lines Matching refs:timeout
86 def put(self, obj, block=True, timeout=None):
89 if not self._sem.acquire(block, timeout):
98 def get(self, block=True, timeout=None):
101 if block and timeout is None:
107 deadline = time.monotonic() + timeout
108 if not self._rlock.acquire(block, timeout):
112 timeout = deadline - time.monotonic()
113 if not self._poll(timeout):
308 def put(self, obj, block=True, timeout=None):
311 if not self._sem.acquire(block, timeout):