您好,欢迎访问一九零五行业门户网

一文聊聊node的多进程和多线程

本篇文章带大家了解一下node.js,介绍一下node中的多进程和多线程,对比一下多进程和多线程,希望对大家有所帮助!
node.js中的多进程与多线程在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('http://localhost:4000/ start')})
上面这串代码,如果http请求了 /compute ,node会调用cpu进行大量的计算,这时如果有其他http请求进入,将会发生阻塞。
那么如何解决这个问题呢?
有两种方案,一种是使用children_process或者cluster开启多进程进行计算,一种是使用worker_thread 开启多线程进行计算
多进程 vs 多线程
对比一下多线程与多进程:
属性多进程多线程比较
数据 数据共享复杂,需要用ipc;数据是分开的,同步简单 因为共享进程数据,数据共享简单,同步复杂 各有千秋
cpu、内存 占用内存多,切换复杂,cpu利用率低 占用内存少,切换简单,cpu利用率高 多线程更好
销毁、切换 创建销毁、切换复杂,速度慢 创建销毁、切换简单,速度很快 多线程更好
coding 编码简单、调试方便 编码、调试复杂 编码、调试复杂
可靠性 进程独立运行,不会相互影响 线程同呼吸共命运 多进程更好
分布式 可用于多机多核分布式,易于扩展 只能用于多核分布式 多进程更好
采用多线程来解决上面代码的计算问题:
//api.jsconst koa = require('koa');const app = new koa();const {worker} = require('worker_threads')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 = new worker(__dirname+'/compute.js') //接收信息 worker.on('message', data => { resolve(data) }) }) ctx.body = {sum} }})app.listen(4000, () => { console.log('http://localhost:4000/ start')})//computer.jsconst {parentport}=require('worker_threads')let sum=0for (let i = 0; i <1000000000 ; i++) { sum+=i}//发送信息parentport.postmessage(sum)
这里是官方文档,worker_threads
https://nodejs.org/dist/latest-v16.x/docs/api/worker_threads.html
采用多进程来解决上面代码的计算问题:
//api.jsconst 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('http://localhost:4000/ start')})//computer.jslet sum=0for (let i = 0; i <1000000000 ; i++) { sum+=i}process.send(sum)
这里是官方文档,child_process
https://nodejs.org/dist/latest-v16.x/docs/api/child_process.html
更多node相关知识,请访问:nodejs 教程!
以上就是一文聊聊node的多进程和多线程的详细内容。
其它类似信息

推荐信息