改名

System/Abstracts/Pool.php

@@ -170,8 +170,9 @@ abstract class Pool extends Component
 		}
 		$time = microtime(true);
 		if (!$this->hasItem($name)) {
-			$this->createByCallback($name, $callback);
+			return $this->createByCallback($name, $callback);
 		}
+
 		$connection = $this->_items[$name]->pop(0.01);
 		if (microtime(true) - $time >= 0.007) {
 			$this->warning('Worker #' . env('worker') . ' get client use time ' . (microtime(true) - $time));
@@ -187,14 +188,17 @@ abstract class Pool extends Component
 	/**
 	 * @param $name
 	 * @param mixed $callback
+	 * @return mixed
 	 * @throws Exception
 	 */
-	private function createByCallback($name, mixed $callback)
+	private function createByCallback($name, mixed $callback): mixed
 	{
 		if ($this->creates === -1 && !is_callable($callback)) {
 			$this->creates = Timer::tick(1000, [$this, 'Heartbeat_detection']);
 		}
 
+		return $this->createClient($name, $callback);
+
 		if (!Context::hasContext('create::client::ing::' . $name)) {
 			$this->push($name, $this->createClient($name, $callback));
 			Context::remove('create::client::ing::' . $name);

System/Pool/Connection.php

@@ -182,6 +182,7 @@ class Connection extends Pool
 	/**
 	 * @param $coroutineName
 	 * @param $isMaster
+	 * @throws Exception
 	 */
 	public function release($coroutineName, $isMaster)
 	{
@@ -190,6 +191,8 @@ class Connection extends Pool
 			return;
 		}
 
+		$this->error('recover db client ' . $coroutineName);
+
 		/** @var PDO $client */
 		$client = Context::getContext($coroutineName);
 		if ($client->inTransaction()) {
@@ -241,7 +244,7 @@ class Connection extends Pool
 		try {
 			if (empty($client) || !($client instanceof PDO)) {
 				$result = false;
-			}  else {
+			} else {
 				$result = true;
 			}
 		} catch (Error | Throwable $exception) {