1 const DynamicThreadPool
= require('../lib/dynamic')
4 const pool
= new DynamicThreadPool(100, 200, './yourWorker.js', { errorHandler
: (e
) => console
.error(e
), onlineHandler
: () => console
.log('worker is online') })
5 pool
.emitter
.on('FullPool', () => maxReached
++)
7 const start
= Date
.now()
8 const iterations
= 1000
9 for (let i
= 0; i
<= iterations
; i
++) {
10 pool
.execute({}).then(res
=> {
12 if (resolved
=== iterations
) {
13 console
.log('Time take is ' + (Date
.now() - start
))
14 console
.log('The pool was full for ' + maxReached
+ ' times')