From 20b135e24e9de9ed47f2f885a13e308ce1b996b1 Mon Sep 17 00:00:00 2001
From: Patrik Oldsberg <poldsberg@gmail.com>
Date: Sun, 13 Feb 2022 21:32:22 +0100
Subject: [PATCH] cli: tweak worker queue to not spawn too many threads and use
 env

Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>
---
 packages/cli/src/lib/parallel.ts | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/packages/cli/src/lib/parallel.ts b/packages/cli/src/lib/parallel.ts
index ec3d5493c0..d51e9b3b2d 100644
--- a/packages/cli/src/lib/parallel.ts
+++ b/packages/cli/src/lib/parallel.ts
@@ -153,13 +153,14 @@ export type WorkerQueueThreadsOptions<TItem, TResult, TData> = {
 export async function runWorkerQueueThreads<TItem, TResult, TData>(
   options: WorkerQueueThreadsOptions<TItem, TResult, TData>,
 ): Promise<TResult[]> {
+  const items = Array.from(options.items);
   const {
     workerFactory,
     workerData,
-    threadCount = os.cpus().length / 2,
+    threadCount = Math.min(getEnvironmentParallelism(), items.length),
   } = options;
 
-  const iterator = options.items[Symbol.iterator]();
+  const iterator = items[Symbol.iterator]();
   const results = new Array<TResult>();
   let itemIndex = 0;