【node.js能做什么】浅析Node.js遇到cpu密集型计算如何优化

更新时间:2019-09-15    来源:php入门    手机版     字体:

【www.bbyears.com--php入门】

首先看下面这段代码

setTimeout(function () {
for (var i = 0; i < 10000000000; i++) {
//CPU密集
}
}, 200);
setTimeout(function () {
console.log("210 ms...");
}, 210);

这个小例子很经典的解释了Node.js遇到密集型CPU的时候问题,这个程序分别在两个时间点触发,虽然在210ms得时候回调内得程序执行非常很快,但是在200ms得时候处理了一个CPU非常密集型的任务就导致整个线程阻塞了.
至于Event Loop机制可以参考:
http://www.infoq.com/cn/articles/nodejs-weakness-cpu-intensive-tasks
这篇文章中关于Event Loop和Tick的一段:

每个Node程序的主线程都有一个event loop,JavaScript代码全在这个单线程下运行。所有的I/O操作以及对本地API的调用,或者是异步的(借助程序所在平台的机制),或者运行在另外的线程中。这全都是通过libuv处理的。所以当socket上有数据过来,或本地API函数返回时,需要有种同步的方式调用对刚发生的这一特定事件感兴趣的JavaScript函数。

在发生事件的线程中直接调用JS函数是不安全的,因为那样也会遇到常规多线程程序遇到的问题,竞态条件、非原子操作的内存访问等等。所以要以一种线程安全的方式把事件放在队列中,如果写成代码,大致应该是这样的:

lock (queue) {
queue.push(event);
}

然后在执行JavaScript的主线程中(即event loop的c代码):

while (true) {
// tick开始
lock (queue) {
var tickEvents = copy(queue);
// 将当前队列中的条目复制的线程自有的内存中
queue.empty(); // ..清空共享的队列
}
for (var i = 0; i < tickEvents.length; i++) {
InvokeJSFunction(tickEvents[i]);
}
// tick结束
}

while (true) (在真正的node源码中并不是这样的;这里只是为了说明)表示event loop。里面的for为队列中的每个事件调用JS函数。Event loop在每个tick中都会调用与外部事件相关联的零个或多个回调函数,一旦队列被清空,并且最后一个函数返回后,tick就结束了。然后回到开始(下一个tick),重新开始检查其它线程在JavaScript运行时加到队列中的事件。

那么这个队列中的东西都是谁放进来的呢?

process.nextTick
setTimeout/setInterval
I/O (来自fs、net等)
crypto中的CPU密集型函数,比如crypto streams、pbkdf2和PRNG
所有使用libuv工作队列异步调用C/C++库的本地模块

同样下面代码当调用t1接口时也会导致t2的接口变慢.

app.get("/t1", function* (next) {
for (var i=0; i<5000000000; i++) {
//cpu密集型
}
console.log("t1");
});
app.get("/t2", function* (next) {
console.log("t2");
});

这么看Node.js是否能够胜任cpu密集型操作呢,答案当然是否定的,Node.js虽然是单线程,但是可以开启多个Node.js实例来充分利用多核的优势,另外Node.js还支持子进程,通过子进程来计算…

for.js

var calc = function() {
for (var i = 0; i < 10000000000; i++) {
}
}
process.on("message", function(m) {
//接收主线程发来消息
console.log("recv mesage");
calc();
process.send(1);
});
process.on("SIGHUP", function() {
process.exit();//收到kill信息,进程退出
});

main.js

var fork = require("child_process").fork;
setTimeout(function () {
var worker = fork("./for.js");
worker.on("message", function(m) {
//接收工作进程的结果
console.log("world");
worker.kill();
});
worker.send(1);
}, 200);
setTimeout(function () {
console.log("hello");
}, 210);

上面这个程序就是利用进程间来通信,for.js是子进程执行的密集型计算.main.js可以继续调度其他程序.充分利用了cpu.

本文来源:http://www.bbyears.com/jiaocheng/68090.html