Skip to content

Commit c7ac437

Browse files
authored
Merge pull request #8 from longxinH/master
优化Task进程判断代码
2 parents 7ad87c7 + a91d835 commit c7ac437

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

src/Server.php

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -601,13 +601,9 @@ public function onManagerStop(swoole_server $server)
601601
*/
602602
public function onWorkerStart(swoole_server $server, $worker_id)
603603
{
604-
if ($server->taskworker) {
605-
process_rename($this->getName() . ' task');
606-
$this->output->write(sprintf('Server Task[<info>%s</info>] is started [<info>%s</info>]', $server->worker_pid, $worker_id) . PHP_EOL);
607-
} else {
608-
process_rename($this->getName() . ' worker');
609-
$this->output->write(sprintf('Server Worker[<info>%s</info>] is started [<info>%s</info>]', $server->worker_pid, $worker_id) . PHP_EOL);
610-
}
604+
$worker_name = $server->taskworker ? 'task' : 'worker';
605+
process_rename($this->getName() . ' ' . $worker_name);
606+
$this->output->write(sprintf('Server %s[<info>%s</info>] is started [<info>%s</info>]', ucfirst($worker_name), $server->worker_pid, $worker_id) . PHP_EOL);
611607
}
612608

613609
/**

0 commit comments

Comments
 (0)