This commit is contained in:
2020-09-01 15:02:21 +08:00
parent f4fbb04525
commit 3d33193716
+2 -1
View File
@@ -7,6 +7,7 @@ use Exception;
use ReflectionException; use ReflectionException;
use Snowflake\Exception\NotFindClassException; use Snowflake\Exception\NotFindClassException;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Process\Pool;
class ServerManager class ServerManager
{ {
@@ -68,7 +69,7 @@ class ServerManager
*/ */
protected static function createProcess($process, $application, $pool, $workerId) protected static function createProcess($process, $application, $pool, $workerId)
{ {
$application->set($pool->getProcess($workerId)); $application->set(Pool::class, $pool);
$process = new $process($application); $process = new $process($application);
$application->debug(sprintf('Worker #%d is running.', $workerId)); $application->debug(sprintf('Worker #%d is running.', $workerId));
return $process->start(); return $process->start();