当 Node.js 主线程被复杂计算阻塞时，使用 worker_threads 模块将任务移至独立线程是标准的隔离方案，适用于图像处理、加密解密或大规模数据计算场景。

核心实现代码

以下示例包含完整的 CPU 密集型任务模拟、主线程卡顿验证及错误处理。请确保 Node.js 版本 >= 10.5.0。

// main.js
const { Worker, isMainThread } = require('worker_threads');

if (isMainThread) {
  const worker = new Worker('./worker.js');
  
  // 验证主线程是否卡顿：每 100ms 打印一次时间戳
  const timer = setInterval(() => {
    console.log('Main thread heartbeat:', Date.now());
  }, 100);

  worker.on('message', msg => {
    console.log('收到结果:', msg);
    clearInterval(timer);
    worker.terminate();
  });

  // 错误处理必须包含，防止子线程崩溃导致主进程异常
  worker.on('error', err => {
    console.error('Worker 错误:', err);
    clearInterval(timer);
  });

  worker.on('exit', code => {
    if (code !== 0) console.error(`Worker 退出码：${code}`);
  });

  // 发送大数据量测试
  worker.postMessage({ type: 'calculate', value: 100000000 });
}

// worker.js
const { parentPort, isMainThread } = require('worker_threads');

if (!isMainThread) {
  parentPort.on('message', msg => {
    if (msg.type === 'calculate') {
      // 模拟 CPU 密集型计算，避免使用简单乘法
      let result = 0;
      for (let i = 0; i < msg.value; i++) {
        result += Math.sqrt(i) * Math.sin(i);
      }
      parentPort.postMessage(result);
    }
  });
}

大数据传输优化

默认情况下线程间内存不共享，大数据传输会触发复制。建议使用 Transferable 对象将 ArrayBuffer 所有权转移给 worker，避免内存拷贝开销。

// main.js 发送端
const buffer = new Uint8Array(1024 * 1024); // 1MB
worker.postMessage({ buffer }, [buffer.buffer]); // 第二个参数为 transferList
console.log(buffer.length); // 转移后主线程中该 buffer 长度为 0

// worker.js 接收端
parentPort.on('message', msg => {
  console.log(msg.buffer.length); // 可正常访问数据
});

验证与排查

运行 node main.js 后，观察控制台输出。

• 成功标志："Main thread heartbeat" 日志间隔稳定在 100ms 左右，即使 worker 正在计算。
• 失败标志：心跳日志出现长时间中断，说明主线程仍被阻塞。
• 排查步骤：检查 worker.js 中是否包裹了 if (!isMainThread)，防止代码在主线程重复执行。

常见坑与风险

1. 不要用于 I/O 任务：网络请求或文件读写本身是异步非阻塞的，用 worker 反而增加序列化和通信开销。

2. 线程创建成本：创建 Worker 有初始化开销，高频短任务（如每次请求都创建）不适合，适合长耗时任务或任务池模式。

3. 上下文隔离：Worker 没有访问主线程全局变量或 DOM 的权限，需通过消息传递数据。

4. 内存泄漏风险：确保在任务完成后调用 worker.terminate() 或让 worker 自然退出，避免僵尸线程。

参考来源

Node.js Official Documentation - Worker Threads

URL: https://nodejs.org/api/worker_threads.html