X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FdynamicExample.js;h=ed1bddebe0e17914992b26d982e477bf95e8e7bc;hb=refs%2Ftags%2Fv2.4.0-0;hp=4003c53462878652804fb8a051feeb792553c051;hpb=583a27ce13d67cc33ded52f46fe1665c64a8fec7;p=poolifier.git diff --git a/examples/dynamicExample.js b/examples/dynamicExample.js index 4003c534..ed1bddeb 100644 --- a/examples/dynamicExample.js +++ b/examples/dynamicExample.js @@ -5,18 +5,18 @@ const pool = new DynamicThreadPool(10, 20, './yourWorker.js', { errorHandler: e => console.error(e), onlineHandler: () => console.log('worker is online') }) -pool.emitter.on('FullPool', () => maxReached++) +pool.emitter.on('busy', () => maxReached++) const start = Date.now() const iterations = 1000 -for (let i = 0; i <= iterations; i++) { +for (let i = 1; i <= iterations; i++) { pool .execute({}) - .then(res => { + .then(() => { resolved++ if (resolved === iterations) { console.log('Time take is ' + (Date.now() - start)) - return console.log('The pool was full for ' + maxReached + ' times') + return console.log('The pool was busy for ' + maxReached + ' times') } return null })