From: Jérôme Benoit <jerome.benoit@piment-noir.org>
Date: Tue, 11 Jun 2024 15:41:11 +0000 (+0200)
Subject: test: add mapExecute() test
X-Git-Tag: v4.0.14~1^2~6
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=2155d8bb7f995ee1dda7eb10bd594039b1fa76f3;p=poolifier.git

test: add mapExecute() test

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---

diff --git a/tests/pools/abstract-pool.test.mjs b/tests/pools/abstract-pool.test.mjs
index ec481d2c..fc346a64 100644
--- a/tests/pools/abstract-pool.test.mjs
+++ b/tests/pools/abstract-pool.test.mjs
@@ -1708,6 +1708,24 @@ describe('Abstract pool test suite', () => {
     await pool.destroy()
   })
 
+  it('Verify mapExecute() is working', async () => {
+    const pool = new DynamicThreadPool(
+      Math.floor(numberOfWorkers / 2),
+      numberOfWorkers,
+      './tests/worker-files/thread/testMultipleTaskFunctionsWorker.mjs'
+    )
+    const results = await pool.mapExecute([{ n: 10 }, { n: 20 }, { n: 30 }, { n: 40 }], 'factorial')
+    expect(results).toStrictEqual([
+      3628800,
+      2432902008176640000,
+      2.6525285981219103e+32,
+      8.159152832478977e+47,
+    ])
+    expect(pool.info.executingTasks).toBe(0)
+    expect(pool.info.executedTasks).toBe(4)
+    await pool.destroy()
+  })
+
   it('Verify that task function objects worker is working', async () => {
     const pool = new DynamicThreadPool(
       Math.floor(numberOfWorkers / 2),