commit 308307190fa6f81c93ef9bb9d95457d14a6ca098
author Giampaolo Rodola' <g.rodola@gmail.com> Wed Apr 17 13:12:27 2013 +0200
committer Giampaolo Rodola' <g.rodola@gmail.com> Wed Apr 17 13:12:27 2013 +0200
tree 26cb44919665dc03933e8c8f6eca2b5ec027466e
parent 22b9e651c2914dcf511665dd80cc9ce10ca53a1d

Fix issue #17707: multiprocessing.Queue's get() method does not block for short timeouts.

Lib/multiprocessing/connection.py

diff --git a/Lib/multiprocessing/connection.py b/Lib/multiprocessing/connection.py
index 4dd6502..47e2123 100644
--- a/Lib/multiprocessing/connection.py
+++ b/Lib/multiprocessing/connection.py
@@ -862,7 +862,7 @@
     if hasattr(select, 'poll'):
         def _poll(fds, timeout):
             if timeout is not None:
-                timeout = int(timeout) * 1000  # timeout is in milliseconds
+                timeout = int(timeout * 1000)  # timeout is in milliseconds
             fd_map = {}
             pollster = select.poll()
             for fd in fds: