• ✔ Fast communication between threads
• ✔ Covers both fixed-task and variable-task scenarios
• ✔ Supports flexible pool sizes
• ✔ Proper async tracking integration
• ✔ Tracking statistics for run and wait times
• ✔ Cancellation Support
• ✔ Supports enforcing memory resource limits
• ✔ Supports CommonJS, ESM, and TypeScript
• ✔ Custom task queues
• ✔ Optional CPU scheduling priorities on Linux

Written in TypeScript.

For Node.js 24.x and higher.

MIT Licensed.

• Website

• piscina - the node.js worker pool

  • Documentation
  • Piscina API
    • Example
    • Exporting multiple worker functions
    • Cancelable Tasks
    • Delaying Availability of Workers
    • Backpressure
    • Out of scope asynchronous code
    • Broadcast a message to all worker threads
    • Additional Examples
  • Class: Piscina
    • Constructor: new Piscina([options])
    • Method: run(task[, options])
    • Method: destroy()
    • Method: close([options])
    • Event: 'error'
    • Event: 'drain'
    • Event: 'needsDrain'
    • Event: 'message'
    • Property: completed (readonly)
    • Property: duration (readonly)
    • Property: options (readonly)
    • Property: runTime (readonly)
    • Property: threads (readonly)
    • Property: idleThreads (readonly)
    • Property: queueSize (readonly)
    • Property: needsDrain (readonly)
    • Property: utilization (readonly)
    • Property: waitTime (readonly)
    • Static property: isWorkerThread (readonly)
    • Static property: version (readonly)
    • Static method: move(value)
      • Interface: Transferable
  • Custom Task Queues
    • Built-In Queues
      • Using FixedQueue Example
  • Current Limitations (Things we're working on / would love help with)
  • Performance Notes
    • Queue Size
    • Queue Pressure and Idle Threads
    • Thread priority on Linux systems
    • Multiple Thread Pools and Embedding Piscina as a Dependency
  • The Team
  • Acknowledgements
  • Sponsors
    • Bronze Sponsors
  • Resources

In main.js:

const path = require("path");
const Piscina = require("piscina");

const piscina = new Piscina({
  filename: path.resolve(__dirname, "worker.js"),
});

(async function () {
  const result = await piscina.run