We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 796bbbc commit 570a490Copy full SHA for 570a490
ThreadPoolExecutorPlus/thread.py
@@ -104,7 +104,7 @@ def run(self):
104
work_item = self._work_queue.get(block=True , timeout = self._keep_alive_time)
105
except queue.Empty:
106
# Got lock problem here , may cause dead lock slightly chance , don't know how to fix it.
107
- with self._executor_free_thread_count_lock:
+ with self._executor._free_thread_count_lock:
108
if self._executor._free_thread_count > self._executor._min_workers:
109
self._executor._free_thread_count -= 1
110
break
0 commit comments