Node.js中如何实现高效的多进程与多线程处理？

本文共计893个文字，预计阅读时间需要4分钟。

本篇文章带大家简单了解一下Node.js，介绍Node中的多进程和多线程，对比多进程和多线程，希望对大家有所帮助！

Node.js中的多进程与多线程在Node.js中，JavaScript代码的执行是单线程的，这意味着同一时间只有一个JavaScript执行栈在运行。然而，Node.js通过以下方式实现了并发处理：

1. 多进程：Node.js利用Node的内置模块`child_process`来创建子进程。每个子进程都有自己的JavaScript执行环境和内存空间，可以并行运行。

2. 多线程：虽然Node.js本身不直接支持多线程，但它通过第三方模块如`worker_threads`来提供线程支持。这使得JavaScript可以在Node.js中运行多线程代码。

多进程与多线程对比- 多进程：适用于CPU密集型任务，每个进程有自己的内存，互不干扰，但进程间通信开销较大。- 多线程：适用于IO密集型任务，线程间通信开销较小，但多个线程共享同一内存空间，存在竞态条件风险。

希望对大家有所帮助！

本篇文章带大家了解一下node.js，介绍一下node中的多进程和多线程，对比一下多进程和多线程，希望对大家有所帮助！

在node.js中，javascript代码的执行是单线程执行的，可是Node 本身其实是多线程的。

node本身分为三层

第一层,Node.js 标准库，这部分是由 Javascript编写的，即我们使用过程中直接能调用的 API,在源码中的 lib 目录下可以看到。

第二层，Node bindings，这一层是 Javascript 与底层 C/C++ 能够沟通的关键，前者通过 bindings 调用后者，相互交换数据，是第一层和第三层的桥梁。

第三层，是支撑 Node.js 运行的关键，由 C/C++ 实现，是node实现的一些底层逻辑。

其中，第三层的Libuv，为 Node.js 提供了跨平台，线程池，事件池，异步 I/O 等能力，是 Node.js 如此强大的关键。

由于Libuv提供了事件循环机制，所以在io处理方面，javascript并不会发生阻塞，所以我们用node搭建web服务时，并不需要担心io量过大，导致其他请求阻塞。

可是，非io任务的执行，是在node主线程中执行的，是单线程执行任务，如果有非常消耗时间的同步计算任务，将会阻塞其他代码的执行。

const Koa = require('koa'); const app = new Koa(); app.use(async (ctx) => { const url = ctx.request.url; if (url === '/') { ctx.body = {name: 'xxx', age: 14} } if(url==='/compute'){ let sum=0 for (let i = 0; i <100000000000 ; i++) { sum+=i } ctx.body={sum} } }) app.listen(4000, () => { console.log('localhost:4000/ start') })

上面这串代码，如果localhost:4000/ start') }) //computer.js const {parentPort}=require('worker_threads') let sum=0 for (let i = 0; i <1000000000 ; i++) { sum+=i } //发送信息 parentPort.postMessage(sum)

这里是官方文档，worker_threads

nodejs.org/dist/latest-v16.x/docs/api/worker_threads.html

采用多进程来解决上面代码的计算问题：

//api.js const Koa = require('koa'); const app = new Koa(); const {fork} = require('child_process') app.use(async (ctx) => { const url = ctx.request.url; if (url === '/') { ctx.body = {name: 'xxx', age: 14} } if (url === '/compute') { const sum = await new Promise(resolve => { const worker =fork(__dirname+'/compute.js') worker.on('message', data => { resolve(data) }) }) ctx.body = {sum} } }) app.listen(4000, () => { console.log('localhost:4000/ start') }) //computer.js let sum=0 for (let i = 0; i <1000000000 ; i++) { sum+=i } process.send(sum)

这里是官方文档，child_process

nodejs.org/dist/latest-v16.x/docs/api/child_process.html

更多node相关知识，请访问：nodejs 教程！