Simple, no frills, threading in Node.js
npm install threadworkthreadwork skips stringifying the function by using a reference instead, reducing the effort to create a threaded function.js
// fibonacci.js
const { ThreadPool } = require('threadwork');function fibonacci(n) {
if (n < 2) return n;
return fibonacci(n - 1) + fibonacci(n - 2);
}
module.exports = new ThreadPool({ task: fibonacci });
`js
// index.js
const pool = require('./fibonacci');(async () => {
try {
const results = await Promise.all([
pool.run(10),
pool.run(20),
pool.run(30)
]);
console.log(results); // [55, 6765, 832040]
} catch (e) {
console.log(e);
} finally {
await pool.close();
}
})();
`API
* - The primary class. It should be instantiated at the top-level and only once per file.
- task - The worker runs this function
- size - The number of workers in the pool (defaults to the number of cores)*
await pool.run(arg1, arg2, ...) - Executes the task once with the arguments provided.*
await pool.close() - Terminates all the workers, allowing the process to exit.*
pool.isMainThread - Allows logic based on whether we're in a worker or not.Compatibility
Node.js 12+ for stable worker_threads$3
There's best-effort support for ts-node-dev. You must provide the following:
1) as an environment variable
2) The same directory should be provided to ts-node-dev via --cache-directoryCLI example:
bash
TS_NODE_DEV_CACHE=.ts-node tsnd --cache-directory $TS_NODE_DEV_CACHE --respawn index.ts
``