docs: refine benchmark README.md
[poolifier.git] / benchmarks / internal / bench.mjs
index 7d3e90f288c478c84dd3cedabba6cb8a371a227a..891ff9eca7118d5bb530e43d23315dcbdfa7c59f 100644 (file)
@@ -10,6 +10,7 @@ import { TaskFunctions } from '../benchmarks-types.mjs'
 import {
   LIST_FORMATTER,
   buildPoolifierPool,
+  getPoolImplementationName,
   runPoolifierTest
 } from '../benchmarks-utils.mjs'
 
@@ -23,7 +24,7 @@ const fixedThreadPool = buildPoolifierPool(
 const taskExecutions = 1
 const workerData = {
   function: TaskFunctions.jsonIntegerSerialization,
-  taskSize: 100
+  taskSize: 1000
 }
 
 const poolifierSuite = new Benchmark.Suite('Poolifier')
@@ -32,7 +33,7 @@ for (const pool of [fixedThreadPool]) {
   for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) {
     for (const enableTasksQueue of [false, true]) {
       poolifierSuite.add(
-        `${pool.constructor.name}|${workerChoiceStrategy}|${
+        `${getPoolImplementationName(pool)}|${workerChoiceStrategy}|${
           enableTasksQueue ? 'with' : 'without'
         } tasks queue`,
         async () => {
@@ -57,10 +58,10 @@ poolifierSuite
   .on('cycle', event => {
     console.info(event.target.toString())
   })
-  .on('complete', function () {
+  .on('complete', async function () {
     console.info(
       'Fastest is ' + LIST_FORMATTER.format(this.filter('fastest').map('name'))
     )
-    fixedThreadPool.destroy()
+    await fixedThreadPool.destroy()
   })
   .run({ async: true })