nodejs多线程怎么实现
更新时间：2023-10-04
[node.js](https://nodejs.org/) 是一种基于 Chrome V8 引擎的 JavaScript 运行时环境，它采用了事件驱动的、非阻塞式 I/O 模型，适用于构建高性能的网络应用。然而，Node.js 是单线程的，所以无法充分利用多核 CPU 的优势。为了实现多线程并发处理，可以通过以下几种方式来实现。
子进程
使用`child_process`模块可以创建子进程，并通过子进程来实现多线程的效果。我们可以通过`spawn()`、`fork()`和`exec()`等方法来创建子进程。 - `spawn()`方法：用于创建一个新的进程并指定一个命令，可以调用系统的可执行文件。 - `fork()`方法：类似于`spawn()`方法，但是只能用于启动脚本文件，并且在子进程中内置了通信通道。 - `exec()`方法：用于执行 Shell 命令，并缓冲任何产生的输出。 下面是一个使用子进程实现多线程的示例代码：
const { spawn } = require('child_process');
const thread1 = spawn('node', ['thread.js']);
const thread2 = spawn('node', ['thread.js']);
thread1.stdout.on('data', (data) => {
console.log(`线程1输出：${data}`);
});
thread2.stdout.on('data', (data) => {
console.log(`线程2输出：${data}`);
});
在上面的示例代码中，我们使用了两个子进程来执行`thread.js`文件，然后通过`stdout`事件监听子进程的输出，达到了多线程的效果。
Worker Threads
Node.js 在 10.5.0 版本引入了官方的实验性模块`worker_threads`，该模块提供了一种在 Node.js 中使用多线程的方法。可以通过创建 `Worker` 实例来创建一个新的线程，并通过`postMessage()`和`on('message')`等方法进行线程间的消息通信。 下面是一个使用`worker_threads`模块实现多线程的示例代码：
const { Worker } = require('worker_threads');
const worker1 = new Worker('./worker.js');
const worker2 = new Worker('./worker.js');
worker1.on('message', (message) => {
console.log(`线程1输出：${message}`);
});
worker2.on('message', (message) => {
console.log(`线程2输出：${message}`);
});
在上面的示例代码中，我们创建了两个`worker.js`的 Worker 实例，然后通过`on('message')`监听消息，并输出到控制台，实现了多线程的效果。
第三方模块
除了上述的原生方法，还有一些第三方模块也可以用于实现多线程，例如 `threads` 和 `webworker-threads` 等。这些模块提供了更高层次的封装，使得多线程的使用更加简单。 `threads` 模块是一个可移植的多线程库，它在后台使用了子进程和消息传递。可以通过`spawn()`方法创建新的线程，并通过消息传递进行线程间的通信。 `webworker-threads` 模块是一个运行在 Node.js 环境中的 web worker 线程库。它在后台使用了线程池，并使用了消息传递进行线程间的通信。使用该模块可以直接在 Node.js 中运行基于 Web Worker 的代码，而无需进行任何修改。
const { spawn } = require('threads');
const thread1 = spawn(function() {
// 在这里编写线程1的代码
});
const thread2 = spawn(function() {
// 在这里编写线程2的代码
});
上述示例代码使用了`threads`模块创建两个新线程，并通过函数传递需要执行的线程代码，从而实现多线程的效果。`webworker-threads`模块的使用方法类似，只需将相应的代码替换即可。
