Remove hyperfine debug option
[poolifier.git] / benchmarks / versus-external-pools / threadjs.js
index a70692bb6e3b3a39eb452063ce9cca716b5d8673..18a01cfd9492ec0b462d39550189fdaa9adbf9c5 100644 (file)
@@ -1,8 +1,8 @@
 // IMPORT LIBRARIES
-const { spawn, Thread, Worker } = require('threads')
+const { spawn, Worker } = require('threads')
 // FINISH IMPORT LIBRARIES
-const size = process.env.POOL_SIZE
-const iterations = process.env.NUM_ITERATIONS
+const size = Number(process.env.POOL_SIZE)
+const iterations = Number(process.env.NUM_ITERATIONS)
 const data = {
   test: 'MYBENCH',
   taskType: process.env['TASK_TYPE']
@@ -11,18 +11,19 @@ const data = {
 // Threads.js is not really a pool so we need to write few additional code
 const workers = []
 async function poolify () {
-  for (let i = 0; i < size ; i++ ){
-    const worker = await spawn(new Worker("./workers/threadjs/function-to-bench-worker.js"))
+  for (let i = 0; i < size; i++) {
+    const worker = await spawn(
+      new Worker('./workers/threadjs/function-to-bench-worker.js')
+    )
     workers.push(worker)
   }
 }
 
-
 async function run () {
   await poolify()
   const promises = []
   for (let i = 0; i < iterations; i++) {
-    const worker = workers[(i % size)]
+    const worker = workers[i % size]
     promises.push(worker.exposedFunction(data))
   }
   await Promise.all(promises)