This commit is contained in:
2020-10-09 16:56:00 +08:00
parent 5eaf38b952
commit f43b3ddbd7
2 changed files with 8 additions and 3 deletions
+5 -1
View File
@@ -214,7 +214,11 @@ class Server extends Application
if (!is_string($process)) {
continue;
}
$system = new $process(Snowflake::app(), $name);
$is_enable_coroutine = true;
if (is_array($process)) {
[$process, $is_enable_coroutine] = $process;
}
$system = new $process(Snowflake::app(), $name, $is_enable_coroutine);
$this->baseServer->addProcess($system);
$application->set($process, $system);
}
+3 -2
View File
@@ -26,9 +26,10 @@ abstract class Process extends \Swoole\Process
* Process constructor.
* @param $application
* @param $name
* @param bool $enable_coroutine
* @throws \Exception
*/
public function __construct($application, $name)
public function __construct($application, $name, $enable_coroutine = true)
{
$class = get_called_class();
parent::__construct(function ($process) use ($name, $class) {
@@ -36,7 +37,7 @@ abstract class Process extends \Swoole\Process
$this->name('Processes: ' . $class . '::class');
}
$this->onHandler($process);
}, false, 1, true);
}, false, 1, $enable_coroutine);
$this->application = $application;
Snowflake::setWorkerId($this->pid);
}