This commit is contained in:
2021-04-28 11:56:19 +08:00
parent b690158a58
commit 20c9e2f8d6
+4 -2
View File
@@ -48,9 +48,9 @@ class OnPipeMessage extends Callback
} }
/** @var Crontab $handler */ /** @var Crontab $handler */
$handler = swoole_unserialize($message['handler']); $handler = swoole_unserialize($message['handler']);
$handler->increment()->execute(); defer(function () use ($handler) {
if ($handler->isRecover() !== 999) { if ($handler->isRecover() !== 999) {
return 'success'; return;
} }
$redis = Snowflake::app()->getRedis(); $redis = Snowflake::app()->getRedis();
@@ -63,6 +63,8 @@ class OnPipeMessage extends Callback
$redis->del('crontab:' . $name); $redis->del('crontab:' . $name);
$redis->del('stop:crontab:' . $name); $redis->del('stop:crontab:' . $name);
} }
});
$handler->increment()->execute();
return 'success'; return 'success';
} }