X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FfixedExample.js;fp=examples%2FfixedExample.js;h=c6ea884897191956ddf2491608bfac175e2c923c;hb=164d950a1bcdc39b4762294c1581e8befbb344e2;hp=2c36a7038695e4e4a8a10dae15bc0f748a4b3849;hpb=3300e7bcb155358c2cc1eed6e4ac11581457616f;p=poolifier.git diff --git a/examples/fixedExample.js b/examples/fixedExample.js index 2c36a703..c6ea8848 100644 --- a/examples/fixedExample.js +++ b/examples/fixedExample.js @@ -1,9 +1,11 @@ const { FixedThreadPool } = require('poolifier') let resolved = 0 +let poolBusy = 0 const pool = new FixedThreadPool(15, './yourWorker.js', { errorHandler: e => console.error(e), onlineHandler: () => console.log('worker is online') }) +pool.emitter.on('busy', () => poolBusy++) const start = Date.now() const iterations = 1000 @@ -13,7 +15,8 @@ for (let i = 1; i <= iterations; i++) { .then(() => { resolved++ if (resolved === iterations) { - return console.log('Time take is ' + (Date.now() - start)) + console.log('Time taken is ' + (Date.now() - start)) + return console.log('The pool was busy for ' + poolBusy + ' times') } return null })