b4d9ecedfad682d0e9a12e1615369327d6b70568
2 const Pool
= require('worker-threads-pool')
3 // FINISH IMPORT LIBRARIES
4 const size
= Number(process
.env
.POOL_SIZE
)
5 const iterations
= Number(process
.env
.NUM_ITERATIONS
)
8 taskType
: process
.env
['TASK_TYPE']
11 const pool
= new Pool({ max
: size
})
13 async
function poolAcquireAsync () {
14 return new Promise((resolve
, reject
) => {
16 './workers/worker-threads-pool/function-to-bench-worker.js',
28 async
function run () {
30 for (let i
= 0; i
< iterations
; i
++) {
31 promises
.push(poolAcquireAsync())
33 await Promise
.all(promises
)