X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=README.md;h=9b1f81317b5a28e920789a096be724b14459f793;hb=12ae3210477b0c54380db24470ff3b0e78926bd8;hp=b86b69eb778f6e3d606701a47e3e55b96881c6cc;hpb=d1affa4c917ac602f06557e3317850bec80f7535;p=poolifier.git diff --git a/README.md b/README.md index b86b69eb..9b1f8131 100644 --- a/README.md +++ b/README.md @@ -113,19 +113,22 @@ Instantiate your pool based on your needed : ```js 'use strict' -const { FixedThreadPool, DynamicThreadPool } = require('poolifier') +const { DynamicThreadPool, FixedThreadPool, PoolEvents } = require('poolifier') // a fixed worker-threads pool const pool = new FixedThreadPool(15, './yourWorker.js', { errorHandler: (e) => console.error(e), onlineHandler: () => console.log('worker is online') }) +pool.emitter.on(PoolEvents.busy, () => console.log('Pool is busy')) + // or a dynamic worker-threads pool const pool = new DynamicThreadPool(10, 100, './yourWorker.js', { errorHandler: (e) => console.error(e), onlineHandler: () => console.log('worker is online') }) -pool.emitter.on('busy', () => console.log('Pool is busy')) +pool.emitter.on(PoolEvents.full, () => console.log('Pool is full')) +pool.emitter.on(PoolEvents.busy, () => console.log('Pool is busy')) // the execute method signature is the same for both implementations, // so you can easy switch from one to another @@ -165,13 +168,28 @@ Node versions >= 16.x are supported. - `WorkerChoiceStrategies.ROUND_ROBIN`: Submit tasks to worker in a round robbin fashion - `WorkerChoiceStrategies.LESS_USED`: Submit tasks to the less used worker - `WorkerChoiceStrategies.LESS_BUSY`: Submit tasks to the less busy worker - - `WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN` Submit tasks to worker using a weighted round robin scheduling algorithm based on tasks execution time + - `WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN`: Submit tasks to worker using a weighted round robin scheduling algorithm based on tasks execution time - `WorkerChoiceStrategies.FAIR_SHARE`: Submit tasks to worker using a fair share tasks scheduling algorithm based on tasks execution time `WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN` and `WorkerChoiceStrategies.FAIR_SHARE` strategies are targeted to heavy and long tasks Default: `WorkerChoiceStrategies.ROUND_ROBIN` +- `workerChoiceStrategyOptions` (optional) - The worker choice strategy options object to use in this pool. + Properties: + + - `medRunTime` (optional) - Use the tasks median run time instead of the tasks average run time in worker choice strategies. + + Default: { medRunTime: false } + - `enableEvents` (optional) - Events emission enablement in this pool. Default: true +- `enableTasksQueue` (optional, experimental) - Tasks queue per worker enablement in this pool. Default: false + +- `tasksQueueOptions` (optional, experimental) - The worker tasks queue options object to use in this pool. + Properties: + + - `concurrency` (optional) - The maximum number of tasks that can be executed concurrently on a worker. + + Default: { concurrency: 1 } ### `pool = new DynamicThreadPool/DynamicClusterPool(min, max, filePath, opts)`