as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2023-04-04 14:44:09 +08:00
parent a25634f07a
commit 1370891b93
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Mysql/PDO.php
+4 -1
View File
@@ -364,9 +364,12 @@ class PDO implements StopHeartbeatCheck
*/ */
private function newClient(): \PDO private function newClient(): \PDO
{ {
while ($this->group->count() > 0) {
Coroutine::sleep(0.0001);
}
$this->group->add(); $this->group->add();
Coroutine::create(function () { Coroutine::create(function () {
\Co\defer(function () { Coroutine::defer(function () {
$this->group->done(); $this->group->done();
}); });
$link = new \PDO('mysql:dbname=' . $this->dbname . ';host=' . $this->cds, $this->username, $this->password, [ $link = new \PDO('mysql:dbname=' . $this->dbname . ';host=' . $this->cds, $this->username, $this->password, [