9af2936b7c0af5f15a6d5830905b62f7e690a70d
2 const WorkerNodes
= require('worker-nodes')
3 const { BenchmarkDefaults
} = require('./utils.mjs')
5 const size
= parseInt(process
.env
.POOL_SIZE
) || BenchmarkDefaults
.poolSize
7 parseInt(process
.env
.NUM_ITERATIONS
) || BenchmarkDefaults
.numIterations
10 taskType
: process
.env
.TASK_TYPE
|| BenchmarkDefaults
.taskType
,
11 taskSize
: parseInt(process
.env
.TASK_SIZE
) || BenchmarkDefaults
.taskSize
14 const workerNodes
= new WorkerNodes(
15 require
.resolve('./workers/worker-nodes/function-to-bench-worker'),
19 taskTimeout
: 60000 // this is the same as poolifier default
23 async
function run () {
24 const promises
= new Set()
25 for (let i
= 0; i
< numIterations
; i
++) {
26 promises
.add(workerNodes
.call
.functionToBench(data
))
28 await Promise
.all(promises
)
29 // eslint-disable-next-line n/no-process-exit
38 // eslint-disable-next-line n/no-process-exit