This commit is contained in:
2021-02-26 19:13:44 +08:00
parent b414846bd5
commit 339a9d7c47
+2 -5
View File
@@ -37,12 +37,12 @@ class OnWorkerStart extends Callback
if (!empty($get_name) && !Snowflake::isMac()) {
swoole_set_process_name($get_name);
}
$this->onTaskSignal($server, $worker_id);
putenv('workerId=' . ($worker_id >= $server->setting['worker_num'] ? 'Task' : 'Worker') . '.' . $worker_id);
if ($worker_id >= $server->setting['worker_num']) {
fire(Event::SERVER_TASK_START);
$this->onTaskSignal($server, $worker_id);
} else {
Snowflake::setWorkerId($server->worker_pid);
$this->setWorkerAction($worker_id);
@@ -62,10 +62,7 @@ class OnWorkerStart extends Callback
if ($sigkill === false) {
return $server->stop($workerId);
}
while ($server->stats()['coroutine_num'] > 1) {
var_dump($server->stats()['coroutine_num']);
while ($server->stats()['tasking_num'] > 0) {
Coroutine::sleep(0.01);
}
return $server->stop($workerId);