bb457af892ff2ff913ecd6317290e016f3ccd63d
5 } = require('poolifier')
7 const pool
= new DynamicThreadPool(
8 Math
.floor(availableParallelism() / 2),
9 availableParallelism(),
12 errorHandler
: e
=> console
.error(e
),
13 onlineHandler
: () => console
.info('worker is online')
18 pool
.emitter
.on(PoolEvents
.full
, () => poolFull
++)
19 pool
.emitter
.on(PoolEvents
.busy
, () => poolBusy
++)
22 const start
= performance
.now()
23 const iterations
= 1000
24 for (let i
= 1; i
<= iterations
; i
++) {
29 if (resolved
=== iterations
) {
30 console
.info('Time taken is ' + (performance
.now() - start
))
31 console
.info('The pool was full for ' + poolFull
+ ' times')
32 return console
.info('The pool was busy for ' + poolBusy
+ ' times')
36 .catch(err
=> console
.error(err
))