@@ -256,7 +256,7 @@ class Scheduler(threading.Thread):
def all_thread_is_done(self):
# Stress 降低偶然性, 因为各个环节不是并发的，很有可能当时状态为假，但检测下一条时该状态为真。一次检测很有可能遇到这种偶然性
- for i in range(3):
+ for i in range(5):
# STEP 5.1 检测 collector 状态
if (
self._collector.is_collector_task()
