()
| 84 | } |
| 85 | |
| 86 | private getAvailableWorker(): PythonWorker | null { |
| 87 | for (const worker of this.workers) { |
| 88 | if (worker.isReady() && !worker.isBusy()) { |
| 89 | return worker; |
| 90 | } |
| 91 | } |
| 92 | return null; |
| 93 | } |
| 94 | |
| 95 | private processQueue(): void { |
| 96 | // Drain the entire queue - process all waiting requests with available workers |
no test coverage detected