改名

System/Pool/ClientsPool.php

@@ -95,7 +95,6 @@ class ClientsPool extends Component
 				if (str_starts_with('Mysql', $key)) {
 					$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $total);
 				}
-
 				$total += $channel->length();
 			}
 			if ($total < 1) {

System/Pool/Connection.php

@@ -202,9 +202,9 @@ class Connection extends Component
 	 * batch release
 	 * @throws Exception
 	 */
-	public function connection_clear()
+	public function connection_clear($name, $isMaster)
 	{
-		$this->getPool()->flush(0);
+		$this->getPool()->clean($this->getPool()->name($name, $isMaster));
 	}
 
 

System/Pool/Redis.php

@@ -108,8 +108,8 @@ class Redis extends Component
 		if (Context::hasContext($coroutineName)) {
 			$this->getPool()->decrement($coroutineName);
 		}
+		$this->getPool()->clean($coroutineName);
 		Context::remove($coroutineName);
-		$this->getPool()->flush(0);
 	}