X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FdynamicExample.js;h=1b7391d759b01c7d6a41dbc0a953bfc33e5f2c8b;hb=f1c0693012b2ec60fe1a0cbf457015b3f874e96f;hp=ed1bddebe0e17914992b26d982e477bf95e8e7bc;hpb=7a6a0a967f5d0978d7ad0714616194fe7592f69a;p=poolifier.git diff --git a/examples/dynamicExample.js b/examples/dynamicExample.js index ed1bddeb..1b7391d7 100644 --- a/examples/dynamicExample.js +++ b/examples/dynamicExample.js @@ -1,13 +1,15 @@ -const { DynamicThreadPool } = require('poolifier') +const { DynamicThreadPool, PoolEvents } = require('poolifier') let resolved = 0 -let maxReached = 0 +let poolFull = 0 +let poolBusy = 0 const pool = new DynamicThreadPool(10, 20, './yourWorker.js', { errorHandler: e => console.error(e), onlineHandler: () => console.log('worker is online') }) -pool.emitter.on('busy', () => maxReached++) +pool.emitter.on(PoolEvents.full, () => poolFull++) +pool.emitter.on(PoolEvents.busy, () => poolBusy++) -const start = Date.now() +const start = performance.now() const iterations = 1000 for (let i = 1; i <= iterations; i++) { pool @@ -15,8 +17,9 @@ for (let i = 1; i <= iterations; i++) { .then(() => { resolved++ if (resolved === iterations) { - console.log('Time take is ' + (Date.now() - start)) - return console.log('The pool was busy for ' + maxReached + ' times') + console.log('Time taken is ' + (performance.now() - start)) + console.log('The pool was full for ' + poolFull + ' times') + return console.log('The pool was busy for ' + poolBusy + ' times') } return null })