node:worker_threads runs scripts on separate threads with
Node’s worker_threads API. elide run does not exit while a worker
runs.
Example
// worker.mjs
import { Worker } from "node:worker_threads";
const source = `
const { parentPort, workerData } = require("node:worker_threads");
parentPort.postMessage(workerData.map((n) => n * n));
`;
const worker = new Worker(source, { eval: true, workerData: [1, 2, 3] });
worker.on("message", (squares) => {
console.log("from worker:", squares.join(" "));
worker.terminate();
});
worker.on("exit", (code) => console.log("worker exited", code));
elide run worker.mjs prints:
from worker: 1 4 9
worker exited 0
Differences from Node
new Workerreads only theworkerData,eval,transferList, andenvoptions.- A missing script file emits
errorwith codeERR_WORKER_PATH. stdoutandstderrare always inherited from the parent.resourceLimitsis{}.- Posting a
ReadableStreamthrowsDataCloneError. - Posting to a terminated worker is a no-op.
--limit=workers=COUNTlimits how many workers a script may start; see Sandbox.
Samples
Reference
Status: Partial · 105 of 128 suite tests pass (82.0%)
worker_threads exports
BroadcastChannel, MessageChannel, MessagePort, Worker, getEnvironmentData, isInternalThread, isMainThread, isMarkedAsUntransferable, markAsUncloneable, markAsUntransferable, moveMessagePortToContext, parentPort, postMessageToThread, receiveMessageOnPort, resourceLimits, setEnvironmentData, threadId, threadName, workerData, 1 constants such as SHARE_ENV
Not implemented
locks.
Tests: node-api node:worker-threads: 105 pass, 22 fail, 1 error, 11 skipped. Failing: test-worker-cleanup-handles.js, test-worker-cpu-profile.js, test-worker-data-url.js, test-worker-eval-typescript.js, test-worker-exit-heapsnapshot.js, test-worker-heap-profile.js, test-worker-heap-snapshot.js, test-worker-heapdump-failure.js, and 15 more.