Skip to content

Commit 265c145

Browse files
author
=
committed
Update
1 parent 1e4f555 commit 265c145

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

ThreadPoolExecutorPlus/thread.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,8 @@ def __init__(self, max_workers=None, thread_name_prefix='',
206206
raise TypeError("initializer must be a callable")
207207

208208
self._max_workers = max_workers
209-
self._work_queue = queue.SimpleQueue(max_workers << 6)
209+
# self._work_queue = queue.Queue(max_workers << 6)
210+
self._work_queue = queue.SimpleQueue()
210211
self._threads = _CustomWeakSet()
211212
self._broken = False
212213
self._shutdown = False

0 commit comments

Comments
 (0)