diff options
| author | Antoine Pitrou <pitrou@free.fr> | 2018-01-18 09:38:03 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-01-18 09:38:03 (GMT) |
| commit | ab74504346a6e2569b3255b7b621c589716888c4 (patch) | |
| tree | 200699b669a4cc8e6896a329db05a5040a19ca5a /Lib/concurrent | |
| parent | 6027802ca7fae118bce6afead51d01a174600d40 (diff) | |
| download | cpython-ab74504346a6e2569b3255b7b621c589716888c4.zip cpython-ab74504346a6e2569b3255b7b621c589716888c4.tar.gz cpython-ab74504346a6e2569b3255b7b621c589716888c4.tar.bz2 | |
bpo-32576: use queue.SimpleQueue in critical places (#5216)
Where a queue may be invoked from a weakref callback, we need
to use the reentrant SimpleQueue.
Diffstat (limited to 'Lib/concurrent')
| -rw-r--r-- | Lib/concurrent/futures/thread.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/Lib/concurrent/futures/thread.py b/Lib/concurrent/futures/thread.py index 2e7100b..6e22950 100644 --- a/Lib/concurrent/futures/thread.py +++ b/Lib/concurrent/futures/thread.py @@ -128,7 +128,7 @@ class ThreadPoolExecutor(_base.Executor): raise TypeError("initializer must be a callable") self._max_workers = max_workers - self._work_queue = queue.Queue() + self._work_queue = queue.SimpleQueue() self._threads = set() self._broken = False self._shutdown = False |