## Node.js versions
-Node.js versions >= 18.x.x are supported.
+Node.js versions >= 20.x.x are supported.
## [API](./docs/api.md)
-'use strict'
-const {
- availableParallelism,
- DynamicThreadPool,
- PoolEvents,
-} = require('poolifier')
+import { availableParallelism, DynamicThreadPool, PoolEvents } from 'poolifier'
const pool = new DynamicThreadPool(
Math.floor(availableParallelism() / 2),
availableParallelism(),
- './yourWorker.js',
+ './yourWorker.mjs',
{
errorHandler: e => console.error(e),
onlineHandler: () => console.info('worker is online'),
-'use strict'
-const {
- availableParallelism,
- FixedThreadPool,
- PoolEvents,
-} = require('poolifier')
+import { availableParallelism, FixedThreadPool, PoolEvents } from 'poolifier'
-const pool = new FixedThreadPool(availableParallelism(), './yourWorker.cjs', {
+const pool = new FixedThreadPool(availableParallelism(), './yourWorker.mjs', {
errorHandler: e => console.error(e),
onlineHandler: () => console.info('worker is online'),
})
-'use strict'
-const { availableParallelism, FixedThreadPool } = require('poolifier')
+import { availableParallelism, FixedThreadPool } from 'poolifier'
const pool = new FixedThreadPool(
availableParallelism(),
- './multiFunctionWorker.cjs',
+ './multiFunctionWorker.mjs',
{
errorHandler: e => console.error(e),
onlineHandler: () => console.info('worker is online'),
-'use strict'
-const { ThreadWorker } = require('poolifier')
+import { ThreadWorker } from 'poolifier'
/**
*
return { data: `fn1 input text was '${data.text}'` }
}
-module.exports = new ThreadWorker({ fn0, fn1 })
+export default new ThreadWorker({ fn0, fn1 })
-'use strict'
-const { ThreadWorker } = require('poolifier')
+import { ThreadWorker } from 'poolifier'
/**
* @returns
return { ok: 1 }
}
-module.exports = new ThreadWorker(yourFunction)
+export default new ThreadWorker(yourFunction)