modify

2021-02-27 03:03:49 +08:00
parent b27f0a2ab6
commit 4303446767
1 changed files with 2 additions and 2 deletions
@@ -45,11 +45,11 @@ class OnWorkerStart extends Callback
        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);
        }
+        $this->onTaskSignal($server, $worker_id);
    }


@@ -69,7 +69,7 @@ class OnWorkerStart extends Callback
                    }
                }
                Snowflake::app()->stateInit();
-                $server->stop($workerId);
+                $server->stop($workerId, true);
            } catch (\Throwable $exception) {
                $this->addError($exception);
            }