变更
This commit is contained in:
@@ -94,7 +94,7 @@ abstract class BaseProcess implements OnProcessInterface
|
|||||||
protected function onShutdown($data): void
|
protected function onShutdown($data): void
|
||||||
{
|
{
|
||||||
$this->isStop = true;
|
$this->isStop = true;
|
||||||
$value = Context::getContext('waite:process:message');
|
$value = Context::get('waite:process:message');
|
||||||
|
|
||||||
\Kiri::getLogger()->alert('Process ' . $this->getName() . ' stop');
|
\Kiri::getLogger()->alert('Process ' . $this->getName() . ' stop');
|
||||||
|
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ class DoWhile
|
|||||||
*/
|
*/
|
||||||
public static function waite(array|\Closure $handler): void
|
public static function waite(array|\Closure $handler): void
|
||||||
{
|
{
|
||||||
if (Context::hasContext('stop')) {
|
if (Context::exists('stop')) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
$handler();
|
$handler();
|
||||||
@@ -29,7 +29,7 @@ class DoWhile
|
|||||||
*/
|
*/
|
||||||
public static function stop(): void
|
public static function stop(): void
|
||||||
{
|
{
|
||||||
Context::setContext('stop', 1);
|
Context::set('stop', 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user