X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=README.md;h=843eab8cc61ca132d9b9441ca516c11dc7659c54;hb=1d3000ff45412827126cbc12cf97fc7053f700af;hp=68e9fe6589ff64573e18eb25a3bd48a8b3ba7650;hpb=b4e93467358d93166716dc6e5075d58c18c961c7;p=poolifier.git diff --git a/README.md b/README.md index 68e9fe65..843eab8c 100644 --- a/README.md +++ b/README.md @@ -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) }) ```