diff --git a/src/Worker/DelegatingWorkerPool.php b/src/Worker/DelegatingWorkerPool.php index abcedfd..33039ca 100644 --- a/src/Worker/DelegatingWorkerPool.php +++ b/src/Worker/DelegatingWorkerPool.php @@ -116,6 +116,11 @@ public function getWorker(): Worker return new PooledWorker($this->selectWorker(), $this->push(...)); } + public function getLimit(): int + { + return $this->limit; + } + public function getWorkerCount(): int { return \min($this->limit, $this->pool->getWorkerCount());