127 lines
2.1 KiB
PHP
127 lines
2.1 KiB
PHP
<?php
|
|
|
|
namespace Server\Abstracts;
|
|
|
|
|
|
use JetBrains\PhpStorm\Pure;
|
|
use Kiri\Kiri;
|
|
use Server\SInterface\OnProcessInterface;
|
|
use Swoole\Coroutine;
|
|
use Swoole\Process;
|
|
|
|
/**
|
|
*
|
|
*/
|
|
abstract class BaseProcess implements OnProcessInterface
|
|
{
|
|
|
|
/** @var bool */
|
|
protected bool $enableSwooleCoroutine = true;
|
|
|
|
|
|
protected bool $isStop = false;
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
public function onProcessStop(): void
|
|
{
|
|
$this->isStop = true;
|
|
}
|
|
|
|
|
|
/**
|
|
* @return bool
|
|
*/
|
|
public function checkProcessIsStop(): bool
|
|
{
|
|
return $this->isStop === true;
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
* @param Process $process
|
|
*/
|
|
public function signListen(Process $process): void
|
|
{
|
|
// if (Coroutine::getCid() === -1) {
|
|
// Process::signal(SIGTERM | SIGKILL, function ($signo) use ($process) {
|
|
// if ($signo) {
|
|
// $lists = Kiri::app()->getProcess();
|
|
// foreach ($lists as $process) {
|
|
// $process->exit(0);
|
|
// }
|
|
// }
|
|
// });
|
|
// } else {
|
|
// Coroutine::create(function () use ($process) {
|
|
// /** @var Coroutine\Socket $message */
|
|
// $message = $process->exportSocket();
|
|
// if ($message->recv() == 0x03455343213212) {
|
|
// $this->waiteExit($process);
|
|
// }
|
|
// });
|
|
// Coroutine::create(function () use ($process) {
|
|
// $data = Coroutine::waitSignal(SIGTERM | SIGKILL, -1);
|
|
// if ($data) {
|
|
// $lists = Kiri::app()->getProcess();
|
|
// foreach ($lists as $name => $process) {
|
|
// foreach ($process as $item) {
|
|
// /** @var Coroutine\Socket $export */
|
|
// $export = $item->exportSocket();
|
|
// $export->send(0x03455343213212);
|
|
// }
|
|
// }
|
|
// }
|
|
// });
|
|
// }
|
|
}
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
protected function exit(): void
|
|
{
|
|
putenv('process.status=idle');
|
|
}
|
|
|
|
|
|
/**
|
|
* @return bool
|
|
*/
|
|
#[Pure] public function isWorking(): bool
|
|
{
|
|
return env('process.status', 'working') == 'working';
|
|
}
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
private function waiteExit(Process $process): void
|
|
{
|
|
$this->onProcessStop();
|
|
while ($this->isWorking()) {
|
|
$this->sleep();
|
|
}
|
|
$process->exit(0);
|
|
}
|
|
|
|
|
|
/**
|
|
*
|
|
*/
|
|
private function sleep(): void
|
|
{
|
|
if ($this->enableSwooleCoroutine) {
|
|
Coroutine::sleep(0.1);
|
|
} else {
|
|
usleep(100);
|
|
}
|
|
}
|
|
|
|
}
|