node.js - 如何使用 async.parallelLimit 来最大化(并行)运行进程的数量？

Question

是否可以使用 async.parallelLimit 为并行运行的进程设置限制？我使用以下非常简单的代码来测试它是如何工作的。

var async = require("async");
var i = 0;

function write() {
    i++;
    console.log("Done", i);
}

async.parallelLimit([
    function(callback) {
        write();
        callback();
    }
], 10, function() {
    console.log("finish");
});

当然，我得到的一切都是这样的:

Done 1
finish

在我的例子中，我有一个经常被调用的函数，但我只希望它同时运行 5 次。其他调用应该排队。 (是的，我知道 async.queue，但这不是我在这个问题中想要的)。

那么现在的问题是，使用 async.parallelLimit 是否可行？

//编辑:

我实际上有类似的东西:

for(var i = 0; i < somthing.length; i++) { //i > 100  for example
    write();
}

并且由于 node.js 的非同步性，这可能会同时运行 100 次。但是在这种情况下我如何限制并行运行的进程？

Answer 1

非常简短的回答；是的。这正是 asyncParallelLimit 所做的。

在您的例子中，您只将一个函数传递给 parallelLimit。这就是为什么它只被调用一次。如果您要多次传递具有相同功能的数组，它会在您将它放入数组中时执行多次。

请注意，您的示例函数实际上并没有异步执行任何工作。因此，此示例函数将始终按顺序执行。如果您有一个执行异步工作的函数，例如网络请求或文件 i/o，它将并行执行。

异步工作负载的更好示例函数是:

function(callback) {
    setTimeout(function(){
        callback();
    }, 200);
}