summaryrefslogtreecommitdiffstats
path: root/Lib/multiprocessing/queues.py
diff options
context:
space:
mode:
authorXiang Zhang <angwerzx@126.com>2017-05-17 13:04:00 (GMT)
committerGitHub <noreply@github.com>2017-05-17 13:04:00 (GMT)
commit6f75bc003ab4d5294b0291289ae03f7a8d305f46 (patch)
tree83a5f81826719a7df0dc6dc5844eb7813a1b526e /Lib/multiprocessing/queues.py
parent0774e79b93cc494b3a957d538c7c112e289973c0 (diff)
downloadcpython-6f75bc003ab4d5294b0291289ae03f7a8d305f46.zip
cpython-6f75bc003ab4d5294b0291289ae03f7a8d305f46.tar.gz
cpython-6f75bc003ab4d5294b0291289ae03f7a8d305f46.tar.bz2
bpo-30301: Fix AttributeError when using SimpleQueue.empty() (#1601)
Under *spawn* and *forkserver* start methods, SimpleQueue.empty() could raise AttributeError due to not setting _poll in __setstate__.
Diffstat (limited to 'Lib/multiprocessing/queues.py')
-rw-r--r--Lib/multiprocessing/queues.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/Lib/multiprocessing/queues.py b/Lib/multiprocessing/queues.py
index dda03dd..a4f4ef8 100644
--- a/Lib/multiprocessing/queues.py
+++ b/Lib/multiprocessing/queues.py
@@ -337,6 +337,7 @@ class SimpleQueue(object):
def __setstate__(self, state):
(self._reader, self._writer, self._rlock, self._wlock) = state
+ self._poll = self._reader.poll
def get(self):
with self._rlock: