WorkerThreads 是 Node.js 的多线程方案，通过独立子线程执行 CPU 密集型任务，避免阻塞主线程事件循环；其核心是消息传递通信、内存隔离，适用于批量处理、数学运算、格式转换等场景。
WorkerThreads 是 Node.js 提供的多线程能力，能让 CPU 密集型任务脱离主线程执行，避免阻塞事件循环，从而缓解服务端计算瓶颈。
为什么主线程容易成为瓶颈
Node.js 默认单线程运行 JavaScript，所有同步计算、循环、加密、图像处理等操作都在主线程完成。一旦遇到耗时长的计算（比如解析大 JSON、生成报表、音视频转码），事件循环就会卡住，导致 HTTP 请求延迟、超时甚至堆积。
即使使用 async/await 或 Promise，也不能让同步计算变“异步”——它们只对 I/O 操作有效，对纯 CPU 运算无效。
WorkerThreads 的核心用法
它通过子线程（Worker）运行独立的 JS 脚本，主线程与 Worker 之间通过消息传递（postMessage + onmessage）通信，内存不共享，避免竞态问题。
立即学习“Java免费学习笔记（深入）”；
- 创建 Worker：用 new Worker(filename, { workerData }) 启动，可传入初始数据
- 发送消息：主线程调用 worker.postMessage(data)，Worker 内监听 parentPort.on('message', ...)
- 返回结果：Worker 调用 parentPort.postMessage(result)，主线程监听 worker.on('message', ...)
- 错误处理：监听 worker.on('error') 和 worker.on('exit') 防止未捕获异常崩溃进程
适合用 WorkerThreads 的典型场景
不是所有任务都值得开线程——线程创建和通信有开销。优先用于：
- 批量数据处理：如读取数万条日志并聚合统计
- 数学密集运算：如矩阵计算、机器学习推理（轻量模型）、密码学哈希
- 格式转换：Markdown 渲染、XML 解析、CSV 生成（尤其大文件）
- 图像缩放或滤镜处理（配合 sharp 等库在 Worker 中调用）
注意：不要在 Worker 中直接操作 global、require 外部模块需显式导入；不能访问 req/res 对象，只能处理纯数据。
简单示例：主线程 + 计算质数的 Worker
主线程（server.js）：
const { Worker } = require('worker_threads');function startPrimeWorker(n) {
const worker = new Worker('./prime_worker.js', { workerData: n });
return new Promise((resolve, reject) => {
worker.on('message', resolve);
worker.on('error', reject);
worker.on('exit', code => { if (code !== 0) reject(new Error(`Worker stopped with exit code ${code}`)); });
});
}
// 在 Express 路由中调用
app.get('/primes/:n', async (req, res) => {
try { const result = await startPrimeWorker(parseInt(req.params.n)); res.json({ result }); }
catch (err) { res.status(500).send(err.message); }
});
Worker 脚本（prime_worker.js）：
const { parentPort, workerData } = require('worker_threads');function findPrimesUpTo(n) { /* 同步筛法实现 */ }
const primes = findPrimesUpTo(workerData);
parentPort.postMessage(primes);
注意事项与优化建议
- 复用 Worker 实例：频繁创建销毁开销大，可用 Worker Pool（如 threads-plugin 或自建队列）管理固定数量 Worker
- 避免大量小消息：高频 postMessage 会拖慢性能，尽量合并数据或用 Transferable（如 ArrayBuffer）零拷贝传输大数组
- 内存监控：每个 Worker 有独立 V8 实例，默认内存上限约 1.4GB，可通过 --max-old-space-size 调整
- 替代方案对比：比 child_process.fork 更轻量（无新 Node 进程开销），但比纯 C++ 插件（N-API）灵活性低；IO 密集型仍首选 async API
