Node.js Worker 线程:实现真正的并行计算
学习使用 worker_threads 模块创建多线程,处理 CPU 密集型任务。 · 难度:入门 · +15XP
为什么需要 Worker 线程?
Node.js 是单线程的,对于 I/O 密集型任务表现优异,但 CPU 密集型任务(如加密、图像处理、大数据排序)会阻塞事件循环。Worker 线程允许你创建真正的操作系统线程,在独立 V8 实例中并行执行 JavaScript 代码。
主线程与 Worker 通信
主线程通过 Worker 构造函数创建 Worker,通过 postMessage 和 on('message') 进行双向通信:
// main.js
const { Worker } = require('worker_threads');
const worker = new Worker('./worker.js');
worker.postMessage({ num: 42 });
worker.on('message', (result) => console.log('结果:', result));
// worker.js
const { parentPort } = require('worker_threads');
parentPort.on('message', (data) => {
const result = data.num * 2;
parentPort.postMessage(result);
});
共享内存
使用 SharedArrayBuffer 可以在线程间共享内存,避免序列化开销:
const { Worker } = require('worker_threads');
const sharedBuffer = new SharedArrayBuffer(4);
const view = new Int32Array(sharedBuffer);
const worker = new Worker('./worker.js');
worker.postMessage({ sharedBuffer });线程池模式
| 优点 | 缺点 |
|---|---|
| 利用多核 CPU | 内存开销增加 |
| 不阻塞主线程 | 通信成本 |
| 隔离错误 | 调试复杂 |
练习提示
右侧代码中,Worker 计算斐波那契数列。请修改 worker.js 部分(在字符串中),实现一个计算斐波那契第 n 项的函数。