NextTick() 不起作用 [将 CPU 密集型任务与其他事件交错]

Question

我正在阅读http://howtonode.org/understanding-process-next-tick 但是，它附带的代码并没有实现 CPU 密集型任务。

我尝试编写我的版本。但这是错误的。

compute() 执行后没有任何 IO 服务。

所以，我的问题是：在这种情况下使用 nextTick() 函数的正确方法是什么？

compute() 执行时我不想阻塞 IO。

var http = require('http');

function compute() {

    // performs complicated calculations continuously
    // ...
    var result = 0;
    for(var i = 0; i < 1000000; i++){
        for(var j = i;  j < 1000000; j++){
            result += i + j;
        }
    }
    process.nextTick(compute);
}

http.createServer(function(req, res) {
    res.writeHead(200, {'Content-Type': 'text/plain'});
    res.end('Hello World');
}).listen(5000, '127.0.0.1');


compute();

Answer 1

nextTick 只是安排你的函数在下一个tick of the event loop 上被调用。它没有赋予该函数神奇的非阻塞属性； JavaScript 仍然是单线程的。如果函数阻塞（通过执行大量 CPU 密集型工作），它仍然会导致 I/O 事件排队，直到函数完成。

如果您需要做 CPU 密集型工作，do it in a worker process。

Answer 2

nextTick 是一个阻塞调用（至少在节点 v0.10.29 中，我对此进行了测试），它阻止其他事件运行。使用 setImmediate()

Answer 3

setImmediate 会更好地工作，正如我在博客文章 setTimeout and Friends 中所解释的那样，因为它将允许 IO 任务在再次锁定主执行线程以完全运行 compute 之前运行。但是正如发布的其他答案所暗示的那样，思考这个问题的方法不是“nextTick 不起作用”，而是“哎呀，我正在尝试做你绝对不能在节点中做的唯一事情之一。 js 应用程序，我得到了我被警告过的结果”。您不能在节点中占用执行线程，因为它是协作多任务处理。将计算分成小块，使用外部进程助手，将某些内容拆分为支持的 C++ 库等。

Answer 4

我会稍微重写你的代码。假设我们需要处理 1000000 个项目，并且有一个（cpu bound，但有时可以调用）函数computeItem() 和 io-bound postItem()。我们希望在后台处理尽可能多的项目，但仍然具有响应式事件循环。为简单起见，没有使用外部工作者/队列/服务。可能的解决方案：

var desiredLatency = 10; // ms

function doBackgroundWork() {
  var start = new Date();
  var end;
  var item; 
  while (item = computeItem()) {
    postItem(item);
    if (end - start >= desiredLatency) {
      setImmediate(doBackgroundWork); // resume at next event loop invocation after processing other handlers
    }
  }
}

http.createServer(function(req, res) {
    res.writeHead(200, {'Content-Type': 'text/plain'});
    res.end('Hello World');
}).listen(5000, '127.0.0.1');
doBackgroundWork();