diff --git a/http-server/ServerManager.php b/http-server/ServerManager.php index 856711dc..eb33d800 100644 --- a/http-server/ServerManager.php +++ b/http-server/ServerManager.php @@ -15,13 +15,13 @@ class ServerManager /** * @param $pool * @param $process - * @param $application * @param $workerId * @return mixed */ - public static function create($pool, $process, $application, $workerId) + public static function create($pool, $process, $workerId) { try { + $application = Snowflake::get(); if (is_string($process) && class_exists($process)) { return static::createProcess($process, $application, $pool, $workerId); } diff --git a/system/Processes.php b/system/Processes.php index 26985e2f..716e90ea 100644 --- a/system/Processes.php +++ b/system/Processes.php @@ -27,10 +27,9 @@ class Processes extends Component */ public function initCore() { - $application = Snowflake::get(); - $server = $application->set(Pool::class, new Pool($this->size(), SWOOLE_IPC_UNIXSOCK)); - $server->on('workerStart', function (Pool $pool, int $workerId) use ($application) { - ServerManager::create($pool, $this->processes[$workerId], $application, $workerId); + $server = new Pool($this->size(), SWOOLE_IPC_UNIXSOCK); + $server->on('workerStart', function (Pool $pool, int $workerId) { + ServerManager::create($pool, $this->processes[$workerId], $workerId); }); $server->on('workerStop', function (Pool $pool, int $workerId) { $event = Snowflake::get()->event;