This commit is contained in:
as2252258@163.com
2021-04-09 02:30:50 +08:00
parent 495cdedcc4
commit 37964440db
+1 -1
View File
@@ -34,7 +34,6 @@ class OnWorkerStart extends Callback
public function actionBefore($server, $worker_id) public function actionBefore($server, $worker_id)
{ {
putenv('state=start'); putenv('state=start');
putenv('worker=' . $worker_id);
$alias = $worker_id >= $server->setting['worker_num'] ? 'task' : 'worker'; $alias = $worker_id >= $server->setting['worker_num'] ? 'task' : 'worker';
@@ -71,6 +70,7 @@ class OnWorkerStart extends Callback
*/ */
public function onHandler(Server $server, int $worker_id): void public function onHandler(Server $server, int $worker_id): void
{ {
putenv('worker=' . $worker_id);
$isWorker = $worker_id < $server->setting['worker_num']; $isWorker = $worker_id < $server->setting['worker_num'];
$this->injectLoader($isWorker); $this->injectLoader($isWorker);