diff --git a/qcloud_cos/cos_threadpool.py b/qcloud_cos/cos_threadpool.py
index 1900d69f..55293551 100644
--- 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