45 lines
861 B
PHP
45 lines
861 B
PHP
<?php
|
|
|
|
|
|
namespace Snowflake\Process;
|
|
|
|
|
|
use Snowflake\Abstracts\Component;
|
|
use Snowflake\Application;
|
|
use Snowflake\Exception\ComponentException;
|
|
use Snowflake\Snowflake;
|
|
use Swoole\Coroutine\Socket;
|
|
use Swoole\Process\Pool;
|
|
|
|
/**
|
|
* Class Process
|
|
* @package Snowflake\Snowflake\Service
|
|
*/
|
|
abstract class Process extends \Swoole\Process
|
|
{
|
|
|
|
/** @var Application $application */
|
|
protected $application;
|
|
|
|
|
|
/**
|
|
* Process constructor.
|
|
* @param $application
|
|
* @param $name
|
|
* @throws \Exception
|
|
*/
|
|
public function __construct($application, $name)
|
|
{
|
|
$class = get_called_class();
|
|
parent::__construct(function ($process) use ($name, $class) {
|
|
if (Snowflake::isLinux()) {
|
|
$this->name($class . ':' . $name);
|
|
}
|
|
$this->onHandler($process);
|
|
}, false, 1, true);
|
|
$this->application = $application;
|
|
Snowflake::setWorkerId($this->pid);
|
|
}
|
|
|
|
}
|