This commit is contained in:
2021-04-27 17:45:36 +08:00
parent 5222c5290f
commit ab3b71d5ba
+3 -3
View File
@@ -168,9 +168,7 @@ abstract class Pool extends Component
if (!Context::inCoroutine()) { if (!Context::inCoroutine()) {
return $this->createClient($name, $callback); return $this->createClient($name, $callback);
} }
if ($this->_items[$name]->isEmpty()) { if (!$this->_items[$name]->isEmpty()) {
return $this->createByCallback($name, $callback);
}
$connection = $this->_items[$name]->pop(); $connection = $this->_items[$name]->pop();
if (!$this->checkCanUse($name, $connection)) { if (!$this->checkCanUse($name, $connection)) {
return $this->createClient($name, $callback); return $this->createClient($name, $callback);
@@ -178,6 +176,8 @@ abstract class Pool extends Component
return $connection; return $connection;
} }
} }
return $this->createByCallback($name, $callback);
}
/** /**