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-07-06 15:38:57 +08:00
parent 31a5053bed
commit ab8a7d7fff
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Pool/ClientsPool.php
+11 -7
View File
@@ -29,6 +29,9 @@ class ClientsPool extends Component
public int $creates = -1; public int $creates = -1;
private array $_times = [];
protected static array $hasCreate = []; protected static array $hasCreate = [];
@@ -91,28 +94,28 @@ class ClientsPool extends Component
*/ */
private function heartbeat_flush() private function heartbeat_flush()
{ {
$min = Config::get('databases.pool.min', 1);
$num = []; $num = [];
$total = 0; $total = 0;
$min = Config::get('databases.pool.min', 1);
foreach (static::$_connections as $key => $channel) { foreach (static::$_connections as $key => $channel) {
if (!isset($num[$key])) { if (!isset($num[$key])) {
$num[$key] = 0; $num[$key] = 0;
} }
$length = $channel->length(); if (time() - $this->_times[$key] ?? time() > 300) {
if ($length > $min) { $this->flush($channel, 0);
} else if ($channel->length() > $min) {
$this->flush($channel, $min); $this->flush($channel, $min);
} }
$num[$key] += $length; $num[$key] += ($length = $channel->length());
if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask()) && $length > 0) { if (str_starts_with($key, 'Mysql') && (Snowflake::isWorker() || Snowflake::isTask()) && $length > 0) {
$this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $length); $this->debug('Worker #' . env('worker') . ' use client -> ' . $key . ':' . $length);
} }
$total += $length; $total += $length;
} }
write(var_export($num,true),'connections'); write(var_export($num, true), 'connections');
if ($total < 1) { if ($total < 1) {
Timer::clear($this->creates); Timer::clear($this->creates);
if (Snowflake::isWorker() || Snowflake::isTask()){ if (Snowflake::isWorker() || Snowflake::isTask()) {
$this->debug('Worker #' . env('worker') . ' clear time tick.'); $this->debug('Worker #' . env('worker') . ' clear time tick.');
} }
$this->creates = -1; $this->creates = -1;
@@ -197,6 +200,7 @@ class ClientsPool extends Component
*/ */
public function getFromChannel($name): mixed public function getFromChannel($name): mixed
{ {
$this->_times[$name] = '';
$channel = $this->getChannel($name); $channel = $this->getChannel($name);
if (!$channel->isEmpty()) { if (!$channel->isEmpty()) {
$connection = $channel->pop(); $connection = $channel->pop();