X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FdynamicExample.js;fp=examples%2FdynamicExample.js;h=6af045601025e3edac7c95a0b670b85b9c37f1f3;hb=6961ca9a305bb2049105e6710a53a4f5f7970cb6;hp=59d992a67e202387d2b3dec6e6b6538e326a9985;hpb=51474716e986601b354cb0be638f68d6100de275;p=poolifier.git diff --git a/examples/dynamicExample.js b/examples/dynamicExample.js index 59d992a6..6af04560 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( + 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++) {