diff --git a/kiri-engine/Pool/PoolQueue.php b/kiri-engine/Pool/PoolQueue.php index 6e67ef24..c0be03b3 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); +// } }