diff --git a/kiri-engine/Pool/PoolQueue.php b/kiri-engine/Pool/PoolQueue.php index c0be03b3..6e67ef24 100644 --- a/kiri-engine/Pool/PoolQueue.php +++ b/kiri-engine/Pool/PoolQueue.php @@ -16,11 +16,11 @@ class PoolQueue implements QueueInterface */ public function __construct(public int $max) { -// if (Context::inCoroutine()) { + if (Context::inCoroutine()) { $this->queue = new Channel($this->max); -// } else { -// $this->queue = new SplQueue($this->max); -// } + } else { + $this->queue = new SplQueue($this->max); + } }