as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-02-28 14:29:38 +08:00
parent a28641ce7e
commit 480e87d70b
1 changed files with 15 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnWorkerStart.php
+15 -16
View File
@@ -37,9 +37,9 @@ class OnWorkerStart extends Callback
public function onHandler(Server $server, int $worker_id): void
{
$container['enable_deadlock_check'] = false;
$container['exit_condition'] = function () {
return Co::stats()['coroutine_num'] === 0;
};
// $container['exit_condition'] = function () {
// return Co::stats()['coroutine_num'] === 0;
// };
Coroutine::set($container);
$get_name = $this->get_process_name($server, $worker_id);
@@ -47,7 +47,7 @@ class OnWorkerStart extends Callback
swoole_set_process_name($get_name);
}
// $this->onSignal($server, $worker_id);
$this->onSignal($server, $worker_id);
if ($worker_id >= $server->setting['worker_num']) {
fire(Event::SERVER_TASK_START);
@@ -64,18 +64,17 @@ class OnWorkerStart extends Callback
* @param $server
* @param $worker_id
*/
// public function onSignal($server, $worker_id)
// {
// $this->debug(sprintf(workerName($worker_id) . ' #%d is start.....', $worker_id));
// Coroutine\go(function (Server $server, $worker_id) {
// Coroutine::waitSignal($this->signal);
// while (Co::stats()['coroutine_num'] > 0) {
// var_dump(Co::stats()['coroutine_num']);
// Coroutine::sleep(1);
// }
// return $server->stop($worker_id, true);
// }, $server, $worker_id);
// }
public function onSignal($server, $worker_id)
{
$this->debug(sprintf(workerName($worker_id) . ' #%d is start.....', $worker_id));
Coroutine\go(function (Server $server, $worker_id) {
Coroutine::waitSignal($this->signal);
while (Snowflake::app()->isRun()) {
Coroutine::sleep(1);
}
return $server->stop($worker_id, true);
}, $server, $worker_id);
}
/**