fix: ensureMinimumWorkers in isolateWorkers

tinylibs · Jun 24, 2022 · 601486e · 601486e
1 parent 25b7629
commit 601486e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 8 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -849,6 +849,7 @@ class ThreadPool {
         // When `isolateWorkers` is enabled, remove the worker after task is finished
         if (this.options.isolateWorkers && taskInfo.workerInfo) {
           this._removeWorker(taskInfo.workerInfo)
+          this._ensureMinimumWorkers()
         }
       },
       signal,

diff --git a/test/simple.test.ts b/test/simple.test.ts
@@ -191,18 +191,13 @@ test('workerId for each thread, that does not go more than maxThreads', async ()
     minThreads: 2,
     maxThreads: 2,
   })
-  await pool.destroy()
 
   expect(pool.run({ slow: true })).resolves.toBe(1)
-  await sleep(10)
-  expect(pool.run({ slow: true })).resolves.toBe(2)
-  await sleep(10)
-  expect(pool.run({ slow: true })).resolves.toBe(1)
-  await sleep(10)
   expect(pool.run({ slow: false })).resolves.toBe(2)
+  expect(pool.run({ slow: true })).resolves.toBe(1)
+  expect(pool.run({ slow: true })).resolves.toBe(2)
 
-  // await pool.destroy()
-  await sleep(300)
+  await sleep(500)
 })
 
 test('workerId should never be more than maxThreads=1', async () => {