X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=README.md;h=07ca907620135eef6ed4d7124ec7a7df69704cf0;hb=HEAD;hp=5ef4138540626b3bc523fbfa9e2277fedbc2d91a;hpb=8ccfa7d88f7fcfa93b1e826f31cc92d7bf288e80;p=poolifier.git
diff --git a/README.md b/README.md
index 5ef41385..43bc095f 100644
--- a/README.md
+++ b/README.md
@@ -2,30 +2,28 @@
-Node.js Worker_Threads and Cluster Worker Pool
-
-
-
- 
-
- 
-
- 
-
- 
-
- 
-
- 
-
- 
-
- 
-
- 
-
- 
-
+
+
+# Node.js Worker_Threads and Cluster Worker Pool
+
+
+
+
+
+[](https://github.com/poolifier/poolifier/graphs/commit-activity)
+[](https://www.npmjs.com/package/poolifier)
+[](https://www.npmjs.com/package/poolifier)
+[](https://jsr.io/@poolifier/poolifier)
+[](https://github.com/poolifier/poolifier/actions/workflows/ci.yml)
+[](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+[](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+[![Javascript Standard Style Guide]()](https://standardjs.com)
+[](https://discord.gg/vXxZhyb3b6)
+[](https://opencollective.com/poolifier)
+[](https://makeapullrequest.com)
+[![No Dependencies]()]()
+
+
## Why Poolifier?
@@ -40,27 +38,28 @@ Please consult our [general guidelines](#general-guidelines).
- Performance [benchmarks](./benchmarks/README.md) :white_check_mark:
- No runtime dependencies :white_check_mark:
- Proper integration with Node.js [async_hooks](https://nodejs.org/api/async_hooks.html) :white_check_mark:
-- Support for CommonJS, ESM, and TypeScript :white_check_mark:
+- Support for CommonJS, ESM and TypeScript :white_check_mark:
- Support for [worker_threads](https://nodejs.org/api/worker_threads.html) and [cluster](https://nodejs.org/api/cluster.html) Node.js modules :white_check_mark:
-- Support for multiple task functions :white_check_mark:
-- Support for sync and async task functions :white_check_mark:
- Tasks distribution strategies :white_check_mark:
- Lockless tasks queueing :white_check_mark:
- Queued tasks rescheduling:
- - Task stealing :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:
+- Support for sync and async task function :white_check_mark:
+- Support for multiple task functions with per task function queuing priority and tasks distribution strategy :white_check_mark:
+- Support for task functions [CRUD](https://en.wikipedia.org/wiki/Create,_read,_update_and_delete) operations at runtime :white_check_mark:
- General guidelines on pool choice :white_check_mark:
- Error handling out of the box :white_check_mark:
- Widely tested :white_check_mark:
- Active community :white_check_mark:
-- Code quality [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
- [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
- [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
- [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
- [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
- [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
-- Code security [](https://sonarcloud.io/dashboard?id=pioardi_poolifier) [](https://sonarcloud.io/dashboard?id=pioardi_poolifier)
+- Code quality [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+ [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+ [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+ [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+ [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+ [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
+- Code security [](https://sonarcloud.io/dashboard?id=poolifier_poolifier) [](https://sonarcloud.io/dashboard?id=poolifier_poolifier)
## Table of contents
@@ -84,17 +83,24 @@ You have to implement your worker by extending the _ThreadWorker_ or _ClusterWor
## Installation
+### npmjs
+
```shell
npm install poolifier --save
```
+### JSR
+
+```shell
+npx jsr add @poolifier/poolifier
+```
+
## Usage
-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_:
+You can implement a poolifier [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,
@@ -110,36 +116,35 @@ 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),
- onlineHandler: () => console.info('worker is online')
+ onlineHandler: () => console.info('worker is online'),
+ errorHandler: e => console.error(e)
})
-pool.emitter.on(PoolEvents.ready, () => console.info('Pool is ready'))
-pool.emitter.on(PoolEvents.busy, () => console.info('Pool is busy'))
+pool.emitter?.on(PoolEvents.ready, () => console.info('Pool is ready'))
+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),
- onlineHandler: () => console.info('worker is online')
+ onlineHandler: () => console.info('worker is online'),
+ errorHandler: e => console.error(e)
})
-pool.emitter.on(PoolEvents.full, () => console.info('Pool is full'))
-pool.emitter.on(PoolEvents.ready, () => console.info('Pool is ready'))
-pool.emitter.on(PoolEvents.busy, () => console.info('Pool is busy'))
+pool.emitter?.on(PoolEvents.full, () => console.info('Pool is full'))
+pool.emitter?.on(PoolEvents.ready, () => console.info('Pool is ready'))
+pool.emitter?.on(PoolEvents.busy, () => console.info('Pool is busy'))
// the execute method signature is the same for both implementations,
// 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)
})
```
@@ -168,7 +173,7 @@ Remember that workers can only send and receive structured-cloneable data.
## Node.js versions
-Node.js versions >= 16.14.x are supported.
+Node.js versions >= 18.x.x are supported.
## [API](./docs/api.md)