X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FfixedExample.js;h=2346f7b4f0b68b207ced0df9ffd86f125e36a1e5;hb=6961ca9a305bb2049105e6710a53a4f5f7970cb6;hp=3f103ca5523f85441fc864172f24f7f142cca477;hpb=15e5141f463661f3dd0f17e8a9402703fddd4050;p=poolifier.git diff --git a/examples/fixedExample.js b/examples/fixedExample.js index 3f103ca5..2346f7b4 100644 --- a/examples/fixedExample.js +++ b/examples/fixedExample.js @@ -1,12 +1,17 @@ -const { FixedThreadPool, PoolEvents } = require('poolifier') -let resolved = 0 -let poolBusy = 0 -const pool = new FixedThreadPool(15, './yourWorker.js', { +const { + FixedThreadPool, + PoolEvents, + availableParallelism +} = require('poolifier') + +const pool = new FixedThreadPool(availableParallelism(), './yourWorker.js', { errorHandler: e => console.error(e), - onlineHandler: () => console.log('worker is online') + onlineHandler: () => console.info('worker is online') }) +let poolBusy = 0 pool.emitter.on(PoolEvents.busy, () => poolBusy++) +let resolved = 0 const start = performance.now() const iterations = 1000 for (let i = 1; i <= iterations; i++) { @@ -15,8 +20,8 @@ for (let i = 1; i <= iterations; i++) { .then(() => { resolved++ if (resolved === iterations) { - console.log('Time taken is ' + (performance.now() - start)) - return console.log('The pool was busy for ' + poolBusy + ' times') + console.info('Time taken is ' + (performance.now() - start)) + return console.info('The pool was busy for ' + poolBusy + ' times') } return null })