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