From 4bb5e44d1c954dcfed7125abcb62ecc4774dab0a Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Sun, 10 Sep 2023 12:09:00 +0200 Subject: [PATCH] refactor: cleanup benchmark code MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- .../dynamic-node-worker-threads-pool.mjs | 4 ++-- benchmarks/versus-external-pools/dynamic-poolifier.mjs | 4 ++-- benchmarks/versus-external-pools/fixed-poolifier.mjs | 4 ++-- .../versus-external-pools/static-node-worker-threads-pool.mjs | 4 ++-- 4 files changed, 8 insertions(+), 8 deletions(-) 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 -- 2.34.1