限制Node.js中的异步调用

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

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

如果我对成千上万的文件执行这个，upload_file会被调用几千次，一次，很可能死(或至少是斗争)。在同步世界中，我们将创建一个线程池并将其限制到一定数量的线程。是否有一种简单的方法来限制同时执行多少个异步调用？

解决方法

像往常一样，我推荐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