keep workthreads before all task done

tencentyun · Dec 5, 2018 · 25a8277 · 25a8277
1 parent 5299470
commit 25a8277
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/qcloud_cos/cos_threadpool.py b/qcloud_cos/cos_threadpool.py
@@ -34,8 +34,6 @@ def run(self):
                 self._ret.append(e)
             finally:
                 self._task_queue.task_done()
-            if self._task_queue.empty():
-                break
 
     def get_result(self):
             return self._succ_task_num, self._fail_task_num, self._ret