async.each/forEachOf在不调用回调的情况下进入下一个迭代

Question

我试图用async遍历异步函数数组中的图像目录。

async.waterfall([ 
function(callback){ 
    async.forEachOf(waterfallObj.sizeDirs, function(sizeDir, index, cb){ 
     //get image files 
     fs.readdir(path.join(__dirname, sizeDir), function(err, files){ 
     tempFiles = files; 
     console.log(index); //0 1 2 3 4 
     //cb(); 
     }); 
    }); 

    callback(null); 
}, /*more functions*/ 
]); 

的想法是，我不想做下一个迭代的forEachOf循环，直到readdir完成读取文件。据我了解，forEachOf不会进入其循环的下一个循环，直到它的回调被调用（就像异步waterfall或series中的每个函数一样。但是即使cb()注释掉了，就像我上面所说的，我仍然看到索引打印了5次。为什么在第一次迭代时不能停止？如果cb没有这样做，我如何确保readdir在下一次迭代之前完成？cb应该做什么，如果不是这样？（我也有同样的效果使用async.each。我应该使用本机forEach也许吧？

Answer 1

这就是异步进程的重点，你不需要等待请求完成才能开始下一个请求。一旦线程空闲（并且，当然，请求已完成），它们中的每一个都会立即调用它的回调函数。

也许你正在寻找承诺的方法，你可以链接你的承诺，以便当一个承诺得到解决时，下一个请求将被解雇并创建一个新的承诺，其中，冗余的，你将能够链接你的第三个请求，等等。