Refine release-it configuration

[poolifier.git] / benchmarks / versus-external-pools / fixed-worker-threads-pool.js

diff --git a/benchmarks/versus-external-pools/fixed-worker-threads-pool.js b/benchmarks/versus-external-pools/fixed-worker-threads-pool.js
index ed7e2ae1db49a3712ab2276e7002d1095d106b2f..b4d9ecedfad682d0e9a12e1615369327d6b70568 100644 (file)
--- 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()