voussoir/voussoirkit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Remove task_done since we never call queue.join.

Browse source
This commit is contained in:
voussoir 2021-11-20 18:48:40 -08:00
parent 039ac45e17
commit 6d9300aa9d
No known key found for this signature in database
GPG key ID: 5F7554F8C26DACCB
1 changed files with 0 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
voussoirkit/threadpool.py
View file

@ -338,11 +338,9 @@ class ThreadPool:
while self._jobs_available.is_set() or not self._result_queue.empty(): while self._jobs_available.is_set() or not self._result_queue.empty():
job = self._result_queue.get() job = self._result_queue.get()
if job is NO_MORE_JOBS: if job is NO_MORE_JOBS:
self._result_queue.task_done()
break break
job.join() job.join()
yield job yield job
self._result_queue.task_done()
self._result_queue = None self._result_queue = None
if was_paused: if was_paused: