diff --git a/kiri-engine/Pool/Pool.php b/kiri-engine/Pool/Pool.php index 26e3adbd..b7bc3f51 100644 --- a/kiri-engine/Pool/Pool.php +++ b/kiri-engine/Pool/Pool.php @@ -65,8 +65,11 @@ class Pool extends Component public function check($name): array { $channel = $this->channel($name); - $count = $success = 0; + if ($channel->length() < 1) { + return [0, 0]; + } + $count = $success = 0; $lists = []; while (($pdo = $channel->pop()) instanceof PDO) { $count += 1; diff --git a/kiri-engine/Pool/SplQueue.php b/kiri-engine/Pool/SplQueue.php index 08376f6f..3fbfba52 100644 --- a/kiri-engine/Pool/SplQueue.php +++ b/kiri-engine/Pool/SplQueue.php @@ -56,6 +56,9 @@ class SplQueue implements QueueInterface public function pop(float $timeout = -1): mixed { // TODO: Implement pop() method. + if ($this->channel->count() < 1) { + return null; + } return $this->channel->dequeue(); }