X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Fversus-external-pools%2Fdynamic-node-worker-threads-pool.mjs;h=c4be1ee1c6d1a0ca312d1597c1d8e4a48406d5fd;hb=f4d1dbd1592e24d7a09f35013c3e0f0762240254;hp=ed8285026c740b93cec25465f6c2835e9a53931f;hpb=479ba9f6225633cd90167c26aa0fe0e79401b989;p=poolifier.git 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..c4be1ee1 100644 --- a/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs +++ b/benchmarks/versus-external-pools/dynamic-node-worker-threads-pool.mjs @@ -1,5 +1,5 @@ import { DynamicPool } from 'node-worker-threads-pool' -import { executeAsyncFn } from '../benchmarks-utils.mjs' +import { executeAsyncFn } from './utils.mjs' import functionToBench from './functions/function-to-bench.js' const size = parseInt(process.env.POOL_SIZE) @@ -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