modify mysql result
This commit is contained in:
+6
-2
@@ -47,8 +47,10 @@ class Inotify extends BaseProcess
|
|||||||
set_exception_handler([$this, 'error']);
|
set_exception_handler([$this, 'error']);
|
||||||
|
|
||||||
if (!extension_loaded('inotify')) {
|
if (!extension_loaded('inotify')) {
|
||||||
$this->cid = Timer::tick(1000, function () {
|
Timer::tick(1000, function ($cid) {
|
||||||
|
if ($this->isStop()) {
|
||||||
|
Timer::clear($cid);
|
||||||
|
}
|
||||||
});
|
});
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -61,6 +63,8 @@ class Inotify extends BaseProcess
|
|||||||
|
|
||||||
public function onSigterm(): static
|
public function onSigterm(): static
|
||||||
{
|
{
|
||||||
|
$this->isStop = true;
|
||||||
|
|
||||||
$this->clear();
|
$this->clear();
|
||||||
|
|
||||||
return parent::onSigterm(); // TODO: Change the autogenerated stub
|
return parent::onSigterm(); // TODO: Change the autogenerated stub
|
||||||
|
|||||||
Reference in New Issue
Block a user