bpo-30595: Fix multiprocessing.Queue.get(timeout) (#2027)

multiprocessing.Queue.get() with a timeout now polls its reader in
non-blocking mode if it succeeded to aquire the lock but the acquire
took longer than the timeout.

Co-Authored-By: Grzegorz Grzywacz <grzgrzgrz3@gmail.com>
This commit is contained in:
Victor Stinner 2017-06-10 13:10:13 +02:00 committed by GitHub
parent 5f31d5cf6e
commit 1b7863c3b6
2 changed files with 6 additions and 2 deletions

View file

@ -101,7 +101,7 @@ class Queue(object):
try:
if block:
timeout = deadline - time.time()
if timeout < 0 or not self._poll(timeout):
if not self._poll(timeout):
raise Empty
elif not self._poll():
raise Empty