node.js - 限制 Node.js 中的异步调用

Question

我有一个 Node.js 应用程序，它在本地获取文件列表并将它们上传到服务器。此列表可能包含数千个文件。

for (var i = 0; i < files.length; i++) {
   upload_file(files[i]);
}

如果我对数千个文件执行此操作，upload_file 将同时被调用数千次，并且很可能会死掉(或者至少是挣扎)。在同步世界中，我们将创建一个线程池并将其限制为一定数量的线程。有没有一种简单的方法来限制一次执行多少个异步调用？

Answer 1

像往常一样，我推荐 Caolan McMahon 的 async module .

让你的 upload_file 函数接受一个回调作为它的第二个参数:

var async = require("async");

function upload_file(file, callback) {
    // Do funky stuff with file
    callback();
}

var queue = async.queue(upload_file, 10); // Run ten simultaneous uploads

queue.drain = function() {
    console.log("All files are uploaded");
};

// Queue your files for upload
queue.push(files);

queue.concurrency = 20; // Increase to twenty simultaneous uploads