X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Fversus-external-pools%2Ffixed-worker-threads-pool.js;h=b4d9ecedfad682d0e9a12e1615369327d6b70568;hb=89e3192b83322814b62e5f5e575d3b8300fcadaa;hp=ed7e2ae1db49a3712ab2276e7002d1095d106b2f;hpb=79e7d3680bb510d4c5419701de6638fb19816c2c;p=poolifier.git

diff --git a/benchmarks/versus-external-pools/fixed-worker-threads-pool.js b/benchmarks/versus-external-pools/fixed-worker-threads-pool.js
index ed7e2ae1..b4d9eced 100644
--- a/benchmarks/versus-external-pools/fixed-worker-threads-pool.js
+++ b/benchmarks/versus-external-pools/fixed-worker-threads-pool.js
@@ -10,17 +10,25 @@ const data = {
 
 const pool = new Pool({ max: size })
 
+async function poolAcquireAsync () {
+  return new Promise((resolve, reject) => {
+    pool.acquire(
+      './workers/worker-threads-pool/function-to-bench-worker.js',
+      {
+        workerData: data
+      },
+      err => {
+        if (err) reject(err)
+        resolve()
+      }
+    )
+  })
+}
+
 async function run () {
   const promises = []
   for (let i = 0; i < iterations; i++) {
-    promises.push(
-      pool.acquire(
-        './workers/worker-threads-pool/function-to-bench-worker.js',
-        {
-          workerData: data
-        }
-      )
-    )
+    promises.push(poolAcquireAsync())
   }
   await Promise.all(promises)
   process.exit()