From: Jérôme Benoit Date: Sun, 10 Sep 2023 10:09:00 +0000 (+0200) Subject: refactor: cleanup benchmark code X-Git-Tag: v2.6.45~37 X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=4bb5e44d1c954dcfed7125abcb62ecc4774dab0a;hp=479ba9f6225633cd90167c26aa0fe0e79401b989;p=poolifier.git refactor: cleanup benchmark code Signed-off-by: Jérôme Benoit --- diff --git a/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs b/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs index ed828502..08535b68 100644 --- a/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs +++ b/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs @@ -10,13 +10,13 @@ const data = { taskSize: parseInt(process.env.TASK_SIZE) } -const pool = new DynamicPool(size) +const dynamicPool = new DynamicPool(size) async function run () { const promises = new Set() for (let i = 0; i < iterations; i++) { promises.add( - pool.exec({ + dynamicPool.exec({ task: functionToBench, param: data, timeout: 60000 // this is the same as poolifier default diff --git a/benchmarks/versus-external-pools/dynamic-poolifier.mjs b/benchmarks/versus-external-pools/dynamic-poolifier.mjs index 4f6a8b40..33ac343c 100644 --- a/benchmarks/versus-external-pools/dynamic-poolifier.mjs +++ b/benchmarks/versus-external-pools/dynamic-poolifier.mjs @@ -9,7 +9,7 @@ const data = { taskSize: parseInt(process.env.TASK_SIZE) } -const dynamicPool = new DynamicThreadPool( +const dynamicThreadPool = new DynamicThreadPool( Math.floor(size / 2), size, './workers/poolifier/function-to-bench-worker.mjs', @@ -21,7 +21,7 @@ const dynamicPool = new DynamicThreadPool( async function run () { const promises = new Set() for (let i = 0; i < iterations; i++) { - promises.add(dynamicPool.execute(data)) + promises.add(dynamicThreadPool.execute(data)) } await Promise.all(promises) // eslint-disable-next-line n/no-process-exit diff --git a/benchmarks/versus-external-pools/fixed-poolifier.mjs b/benchmarks/versus-external-pools/fixed-poolifier.mjs index cbc7410d..7cfd651d 100644 --- a/benchmarks/versus-external-pools/fixed-poolifier.mjs +++ b/benchmarks/versus-external-pools/fixed-poolifier.mjs @@ -9,7 +9,7 @@ const data = { taskSize: parseInt(process.env.TASK_SIZE) } -const fixedPool = new FixedThreadPool( +const fixedThreadPool = new FixedThreadPool( size, './workers/poolifier/function-to-bench-worker.mjs', { @@ -20,7 +20,7 @@ const fixedPool = new FixedThreadPool( async function run () { const promises = new Set() for (let i = 0; i < iterations; i++) { - promises.add(fixedPool.execute(data)) + promises.add(fixedThreadPool.execute(data)) } await Promise.all(promises) // eslint-disable-next-line n/no-process-exit diff --git a/benchmarks/versus-external-pools/static-node-worker-threads-pool.mjs b/benchmarks/versus-external-pools/static-node-worker-threads-pool.mjs index 3275d6f2..d37677cd 100644 --- a/benchmarks/versus-external-pools/static-node-worker-threads-pool.mjs +++ b/benchmarks/versus-external-pools/static-node-worker-threads-pool.mjs @@ -10,7 +10,7 @@ const data = { taskSize: parseInt(process.env.TASK_SIZE) } -const pool = new StaticPool({ +const staticPool = new StaticPool({ size, task: functionToBench }) @@ -18,7 +18,7 @@ const pool = new StaticPool({ async function run () { const promises = new Set() for (let i = 0; i < iterations; i++) { - promises.add(pool.exec(data)) + promises.add(staticPool.exec(data)) } await Promise.all(promises) // eslint-disable-next-line n/no-process-exit