优化代码

Yurunsoft · Yurunsoft · commit f58dfa53c2f3 · 2020-07-21T11:23:31.000+08:00
diff --git a/src/Service/BaseQueueConsumer.php b/src/Service/BaseQueueConsumer.php
@@ -122,10 +122,7 @@ public function run(ITaskParam $param)
                     'task'  =>  $task,
                 ]);
             }
-            while($pool->isRunning())
-            {
-                Coroutine::sleep(0.1);
-            }
+            $pool->wait();
         }
         else
         {

Original file line number	Diff line number	Diff line change
`@@ -122,10 +122,7 @@ public function run(ITaskParam $param)`
`122`	`122`	`'task' => $task,`
`123`	`123`	`]);`
`124`	`124`	`}`
`125`		`- while($pool->isRunning())`
`126`		`- {`
`127`		`- Coroutine::sleep(0.1);`
`128`		`- }`
	`125`	`+ $pool->wait();`
`129`	`126`	`}`
`130`	`127`	`else`
`131`	`128`	`{`