改名

src/Mysql/PDO.php

@@ -4,7 +4,6 @@ namespace Database\Mysql;
 
 use Exception;
 use Kiri\Abstracts\Logger;
-use Kiri\Context;
 use Kiri\Kiri;
 use Kiri\Pool\StopHeartbeatCheck;
 use PDOStatement;
@@ -67,8 +66,17 @@ class PDO implements StopHeartbeatCheck
 		if (env('state', 'start') == 'exit') {
 			return;
 		}
-		if ($this->_timer === -1 && Context::inCoroutine()) {
-			$this->_timer = Timer::tick(1000, function () {
+		if ($this->_timer === -1) {
+			$this->_timer = Timer::tick(1000, fn() => $this->waite());
+		}
+	}
+
+
+	/**
+	 * @throws Exception
+	 */
+	private function waite(): void
+	{
 		try {
 			if (env('state', 'start') == 'exit') {
 				Kiri::getDi()->get(Logger::class)->critical('timer end');
@@ -81,8 +89,6 @@ class PDO implements StopHeartbeatCheck
 		} catch (\Throwable $throwable) {
 			error($throwable);
 		}
-			});
-		}
 	}