X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=README.md;h=843eab8cc61ca132d9b9441ca516c11dc7659c54;hb=59cdd8171e644866f2e8247a4e5f52000fbf88d9;hp=b2b80c2b02e9d2369c7fbbcf470df3990102718b;hpb=58c0dd01a282b063f30a1d4b71b98d1426239c04;p=poolifier.git diff --git a/README.md b/README.md index b2b80c2b..843eab8c 100644 --- a/README.md +++ b/README.md @@ -44,7 +44,7 @@ Please consult our [general guidelines](#general-guidelines). - Tasks distribution strategies :white_check_mark: - Lockless tasks queueing :white_check_mark: - Queued tasks rescheduling: - - Task stealing on empty queue :white_check_mark: + - Task stealing on idle :white_check_mark: - Tasks stealing under back pressure :white_check_mark: - Tasks redistribution on worker error :white_check_mark: - General guidelines on pool choice :white_check_mark: @@ -90,8 +90,7 @@ npm install poolifier --save You can implement a [worker_threads](https://nodejs.org/api/worker_threads.html#class-worker) worker in a simple way by extending the class _ThreadWorker_: ```js -'use strict' -const { ThreadWorker } = require('poolifier') +import { ThreadWorker } from 'poolifier' function yourFunction(data) { // this will be executed in the worker thread, @@ -107,12 +106,11 @@ module.exports = new ThreadWorker(yourFunction, { Instantiate your pool based on your needs : ```js -'use strict' -const { DynamicThreadPool, FixedThreadPool, PoolEvents, availableParallelism } = require('poolifier') +import { DynamicThreadPool, FixedThreadPool, PoolEvents, availableParallelism } from 'poolifier' // a fixed worker_threads pool const pool = new FixedThreadPool(availableParallelism(), './yourWorker.js', { - errorHandler: (e) => console.error(e), + errorHandler: e => console.error(e), onlineHandler: () => console.info('worker is online') }) @@ -121,7 +119,7 @@ pool.emitter?.on(PoolEvents.busy, () => console.info('Pool is busy')) // or a dynamic worker_threads pool const pool = new DynamicThreadPool(Math.floor(availableParallelism() / 2), availableParallelism(), './yourWorker.js', { - errorHandler: (e) => console.error(e), + errorHandler: e => console.error(e), onlineHandler: () => console.info('worker is online') }) @@ -133,10 +131,10 @@ pool.emitter?.on(PoolEvents.busy, () => console.info('Pool is busy')) // so you can easily switch from one to another pool .execute() - .then((res) => { + .then(res => { console.info(res) }) - .catch((err) => { + .catch(err => { console.error(err) }) ```