Skip to content

Commit 207e476

Browse files
authored
Update thread.py
1 parent bd939b7 commit 207e476

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ThreadPoolExecutorPlus/thread.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -225,9 +225,9 @@ def __init__(self, max_workers=None, thread_name_prefix='',
225225
self._threads = _CustomWeakSet()
226226
self._broken = False
227227
self._shutdown = False
228-
self._shutdown_lock = threading.Lock()
228+
self._shutdown_lock = threading.RLock()
229229
self._free_thread_count = 0
230-
self._free_thread_count_lock = threading.Lock()
230+
self._free_thread_count_lock = threading.RLock()
231231
self._thread_name_prefix = (thread_name_prefix or
232232
("ThreadPoolExecutor-%d" % self._counter()))
233233
self._initializer = initializer

0 commit comments

Comments
 (0)