改名
This commit is contained in:
@@ -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);
|
||||
}
|
||||
|
||||
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user