X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2FdynamicExample.js;fp=examples%2FdynamicExample.js;h=0000000000000000000000000000000000000000;hb=7a923e5bc16ae3524c51bedd70c65ce6cc556fdc;hp=ad79ba20294135dfc4569f1795151ae24f8ea3fc;hpb=b2b02b3dade2a6fe409865e05c11ed20e466c920;p=poolifier.git diff --git a/examples/dynamicExample.js b/examples/dynamicExample.js deleted file mode 100644 index ad79ba20..00000000 --- a/examples/dynamicExample.js +++ /dev/null @@ -1,41 +0,0 @@ -'use strict' -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 poolReady = 0 -let poolBusy = 0 -pool.emitter.on(PoolEvents.full, () => poolFull++) -pool.emitter.on(PoolEvents.ready, () => poolReady++) -pool.emitter.on(PoolEvents.busy, () => poolBusy++) - -let resolved = 0 -const start = performance.now() -const iterations = 1000 -for (let i = 1; i <= iterations; i++) { - pool - .execute() - .then(() => { - resolved++ - if (resolved === iterations) { - console.info('Time taken is ' + (performance.now() - start)) - console.info('The pool was full for ' + poolFull + ' times') - console.info('The pool was ready for ' + poolReady + ' times') - return console.info('The pool was busy for ' + poolBusy + ' times') - } - return null - }) - .catch(err => console.error(err)) -}