1

src/main.py

@@ -77,28 +77,27 @@ def exec(thread_id):
 
 def run():
     brush_thread = 2
-    while True:
 
-        print(f'本次并发数 {brush_thread}')
-
-        # pool = ThreadPoolExecutor(max_workers=brush_thread)
-        # all_task = [pool.submit(exec, (i)) for i in range(brush_group)]
-        # brush_check = CONFIG['internal']['reverse']['making']['brush_check']
-        # wait(all_task, return_when=ALL_COMPLETED)
-        # print(f'休息 {brush_check} 秒')
-        # time.sleep(brush_check)
-
-        with ThreadPoolExecutor(max_workers=brush_thread) as executor:
-            objs = []
-            for t in range(1, brush_thread + 1):
-                task = executor.submit(exec, t)
-                objs.append(task)
-            while 1:
-                time.sleep(1)
-                for n, o in enumerate(objs):
-                    if o.done():
-                        task = executor.submit(exec, n + 1)
-                        objs[n] = task
+    print(f'本次并发数 {brush_thread}')
+
+    # pool = ThreadPoolExecutor(max_workers=brush_thread)
+    # all_task = [pool.submit(exec, (i)) for i in range(brush_group)]
+    # brush_check = CONFIG['internal']['reverse']['making']['brush_check']
+    # wait(all_task, return_when=ALL_COMPLETED)
+    # print(f'休息 {brush_check} 秒')
+    # time.sleep(brush_check)
+
+    with ThreadPoolExecutor(max_workers=brush_thread) as executor:
+        objs = []
+        for t in range(1, brush_thread + 1):
+            task = executor.submit(exec, t)
+            objs.append(task)
+        while 1:
+            time.sleep(1)
+            for n, o in enumerate(objs):
+                if o.done():
+                    task = executor.submit(exec, n + 1)
+                    objs[n] = task
 
 
 if __name__ == '__main__':