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

改名

Browse Source
This commit is contained in:
Mr·x
2021-02-17 00:06:03 +08:00
parent 3877b0fb29
commit c0a2476e7c
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Abstracts/Pool.php
+5 -7
View File
@@ -45,7 +45,6 @@ abstract class Pool extends Component
} }
/** /**
* @param $name * @param $name
* @return array * @return array
@@ -68,7 +67,6 @@ abstract class Pool extends Component
} }
/** /**
* @param $cds * @param $cds
* @param false $isMaster * @param false $isMaster
@@ -126,13 +124,13 @@ abstract class Pool extends Component
*/ */
public function createConnect(array $config, string $coroutineName, callable $createHandler): PDO|Redis|false public function createConnect(array $config, string $coroutineName, callable $createHandler): PDO|Redis|false
{ {
if (Context::hasContext('create:connect:' . $coroutineName)) { if ($client = Context::getContext($coroutineName)) {
while (($client = Context::getContext($coroutineName)) != null){
var_dump($client);
}
var_dump($client);
return $client; return $client;
} }
if (Context::hasContext('create:connect:' . $coroutineName)) {
Coroutine::sleep(0.001);
return $this->createConnect($config, $coroutineName, $createHandler);
}
Context::setContext('create:connect:' . $coroutineName, 1); Context::setContext('create:connect:' . $coroutineName, 1);
$client = call_user_func($createHandler, ...$config); $client = call_user_func($createHandler, ...$config);