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