X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FdynamicExample.js;h=bb457af892ff2ff913ecd6317290e016f3ccd63d;hb=f294681c4244effd6671e9d3534bf54bbf122d7a;hp=59d992a67e202387d2b3dec6e6b6538e326a9985;hpb=b99a3b7852074303d5e17781080235f30d68e6b6;p=poolifier.git diff --git a/examples/dynamicExample.js b/examples/dynamicExample.js index 59d992a6..bb457af8 100644 --- a/examples/dynamicExample.js +++ b/examples/dynamicExample.js @@ -1,14 +1,24 @@ -const { DynamicThreadPool, PoolEvents } = require('poolifier') -let resolved = 0 +const { + DynamicThreadPool, + PoolEvents, + availableParallelism +} = require('poolifier') + +const pool = new DynamicThreadPool( + Math.floor(availableParallelism() / 2), + availableParallelism(), + './yourWorker.js', + { + errorHandler: e => console.error(e), + onlineHandler: () => console.info('worker is online') + } +) let poolFull = 0 let poolBusy = 0 -const pool = new DynamicThreadPool(10, 20, './yourWorker.js', { - errorHandler: e => console.error(e), - onlineHandler: () => console.info('worker is online') -}) pool.emitter.on(PoolEvents.full, () => poolFull++) pool.emitter.on(PoolEvents.busy, () => poolBusy++) +let resolved = 0 const start = performance.now() const iterations = 1000 for (let i = 1; i <= iterations; i++) {