1 const { DynamicThreadPool
} = require('../../../lib/index')
5 const dynamicPool
= new DynamicThreadPool(size
/ 2, size
* 3, './worker.js')
7 async
function dynamicThreadTest (
8 { tasks
, workerData
} = { tasks
: 1, workerData
: { proof
: 'ok' } }
10 return new Promise((resolve
, reject
) => {
12 for (let i
= 0; i
<= tasks
; i
++) {
17 if (executions
=== tasks
) {
18 return resolve('FINISH')
22 .catch(err
=> console
.error(err
))
27 module
.exports
= { dynamicThreadTest
}