as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2022-10-11 17:35:42 +08:00
parent af60e61c5c
commit 0b179f9739
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-actor/Actor.php
+11 -1
View File
@@ -2,6 +2,7 @@
namespace Kiri\Actor; namespace Kiri\Actor;
use Exception;
use JsonSerializable; use JsonSerializable;
use Swoole\Coroutine; use Swoole\Coroutine;
use Swoole\Coroutine\Channel; use Swoole\Coroutine\Channel;
@@ -172,9 +173,13 @@ abstract class Actor implements ActorInterface, JsonSerializable
/** /**
* @return void * @return void
* @throws Exception
*/ */
public function run(): void public function run(): void
{ {
if ($this->refreshInterval < 1) {
throw new Exception('Refresh interval must be greater than 1');
}
$this->setState(ActorState::BUSY); $this->setState(ActorState::BUSY);
$this->init(); $this->init();
$this->messageId = Coroutine::create(fn() => $this->loop()); $this->messageId = Coroutine::create(fn() => $this->loop());
@@ -191,7 +196,12 @@ abstract class Actor implements ActorInterface, JsonSerializable
if ($this->isShutdown()) { if ($this->isShutdown()) {
return; return;
} }
$this->onUpdate();
try {
$this->onUpdate();
} catch (\Throwable $exception) {
\Kiri::getLogger()->error(throwable($exception));
}
Coroutine::sleep($this->refreshInterval / 1000); Coroutine::sleep($this->refreshInterval / 1000);