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

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-05-04 03:09:07 +08:00
parent a8eebeb902
commit 10b4aa28fe
1 changed files with 279 additions and 275 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Abstracts/Pool.php
+4
View File
@@ -101,6 +101,7 @@ abstract class Pool extends Component
$names[] = $name; $names[] = $name;
$this->pop($channel, $name, $retain_number); $this->pop($channel, $name, $retain_number);
} }
$this->_items = [];
if ($retain_number == 0) { if ($retain_number == 0) {
Timer::clear($this->creates); Timer::clear($this->creates);
$this->creates = -1; $this->creates = -1;
@@ -128,6 +129,9 @@ abstract class Pool extends Component
*/ */
protected function pop($channel, $name, $retain_number): void protected function pop($channel, $name, $retain_number): void
{ {
if (Coroutine::getCid() === -1) {
return;
}
while ($channel->length() > $retain_number) { while ($channel->length() > $retain_number) {
$connection = $channel->pop(); $connection = $channel->pop();
if ($connection) { if ($connection) {