This commit is contained in:
as2252258@163.com
2021-02-27 03:18:54 +08:00
parent fd6d84ded1
commit 7f0bb7fcff
+4 -4
View File
@@ -37,6 +37,9 @@ class OnWorkerStart extends Callback
public function onHandler(Server $server, int $worker_id): void public function onHandler(Server $server, int $worker_id): void
{ {
Coroutine::set(['enable_deadlock_check' => false]); Coroutine::set(['enable_deadlock_check' => false]);
Coroutine::create(function () use ($server, $worker_id) {
$this->onTaskSignal($server, $worker_id);
});
$get_name = $this->get_process_name($server, $worker_id); $get_name = $this->get_process_name($server, $worker_id);
if (!empty($get_name) && !Snowflake::isMac()) { if (!empty($get_name) && !Snowflake::isMac()) {
@@ -50,7 +53,6 @@ class OnWorkerStart extends Callback
Snowflake::setWorkerId($server->worker_pid); Snowflake::setWorkerId($server->worker_pid);
$this->setWorkerAction($worker_id); $this->setWorkerAction($worker_id);
} }
$this->onTaskSignal($server, $worker_id);
} }
@@ -61,7 +63,6 @@ class OnWorkerStart extends Callback
*/ */
public function onTaskSignal(Server $server, int $workerId) public function onTaskSignal(Server $server, int $workerId)
{ {
go(function () use ($server, $workerId) {
try { try {
$sigkill = Coroutine::waitSignal(SIGKILL | SIGUSR1); $sigkill = Coroutine::waitSignal(SIGKILL | SIGUSR1);
var_dump($sigkill); var_dump($sigkill);
@@ -70,12 +71,11 @@ class OnWorkerStart extends Callback
Coroutine::sleep(1); Coroutine::sleep(1);
} }
} }
$server->stop(); // $server->stop();
Process::kill($server->worker_pid, SIGKILL); Process::kill($server->worker_pid, SIGKILL);
} catch (\Throwable $exception) { } catch (\Throwable $exception) {
$this->addError($exception); $this->addError($exception);
} }
});
} }