This commit is contained in:
2021-02-26 20:04:16 +08:00
parent 893b0abb58
commit 8f9b75d19f
2 changed files with 2 additions and 3 deletions
+1 -2
View File
@@ -64,8 +64,7 @@ class OnWorkerStart extends Callback
if ($sigkill === false) { if ($sigkill === false) {
return $server->stop($workerId); return $server->stop($workerId);
} }
while ($server->stats()['coroutine_num'] > 0) { while (Snowflake::app()->isRun()) {
var_dump($server->stats()['coroutine_num']);
sleep(1); sleep(1);
} }
return $server->stop($workerId); return $server->stop($workerId);
+1 -1
View File
@@ -106,7 +106,7 @@ abstract class BaseApplication extends Service
public function increment() public function increment()
{ {
$this->taskNumber += 1; $this->taskNumber += 1;
if ($this->taskNumber <= 1) { if ($this->taskNumber < 1) {
$this->taskNumber = 0; $this->taskNumber = 0;
$this->state = 'SWOOLE_WORKER_IDLE'; $this->state = 'SWOOLE_WORKER_IDLE';
} else { } else {