嵌套节点async.eachSeries
与异步模块一起工作了半天，但在嵌套几个级别时无法正常工作。 由于代码有点冗长的帖子，但请裸露在我身边，所有的代码应该运行良好。
所以这工作正常：
var async = require('async')
var myarr = ["Outer - A", "Outer - B"];
var myarr2 = ["Inner - A", "Inner - B"];
var innerComplete = true;
async.eachSeries(myarr, function( item, outerCallback) {
console.log('Processing item ' + item);
async.series([
function(callback) {
takeTime(2000, item, callback)
},
function(callback) {
takeTime(1000, item, callback)
},
function(callback) {
outerCallback();
}
], function(err) {
console.log("---OUTER SEQUENCE---")
})
}, function(err){
console.log("---OUTER LOOP---")
});
function takeTime(ms, msg, callback) {
console.log("Starting " + ms + " ms task from " + msg);
setTimeout( function() {
console.log("Finished " + ms + " ms task from " + msg);
callback();
}, ms);
}
并且它按照如下顺序输出一切：
Processing item Outer - A Starting 2000 ms task from Outer - A Finished 2000 ms task from Outer - A Starting 1000 ms task from Outer - A Finished 1000 ms task from Outer - A Processing item Outer - B Starting 2000 ms task from Outer - B Finished 2000 ms task from Outer - B Starting 1000 ms task from Outer - B Finished 1000 ms task from Outer - B ---OUTER LOOP---
但是，当我试图嵌套另一个eachSeries循环到它像这样：
var async = require('async')
var myarr = ["Outer - A", "Outer - B"];
var myarr2 = ["Inner - A", "Inner - B"];
var innerComplete = true;
async.eachSeries(myarr, function( item, outerCallback) {
console.log('Processing item ' + item);
async.series([
function(callback) {
takeTime(2000, item, callback)
},
function(callback) {
takeTime(1000, item, callback)
},
function(callback) {
async.eachSeries(myarr2, function( item2, outerCallback2) {
console.log('Processing item ' + item2);
async.series([
function(callback2) {
takeTime(2000, item2, callback2)
},
function(callback2) {
takeTime(1000, item2, callback2)
}
], function(err) {
console.log('---INNER SEQUENCE---')
})
}, function(err){
console.log("---INNER LOOP---")
});
outerCallback();
}
], function(err) {
console.log("---OUTER SEQUENCE---")
})
}, function(err){
console.log("---OUTER LOOP---")
});
function takeTime(ms, msg, callback) {
console.log("Starting " + ms + " ms task from " + msg);
setTimeout( function() {
console.log("Finished " + ms + " ms task from " + msg);
callback();
}, ms);
}
进入第二个eachSeries循环时会失去执行顺序，如下所示：
Processing item Outer - A Starting 2000 ms task from Outer - A Finished 2000 ms task from Outer - A Starting 1000 ms task from Outer - A Finished 1000 ms task from Outer - A Processing item Inner - A Starting 2000 ms task from Inner - A Processing item Outer - B Starting 2000 ms task from Outer - B Finished 2000 ms task from Inner - A Starting 1000 ms task from Inner - A Finished 2000 ms task from Outer - B Starting 1000 ms task from Outer - B Finished 1000 ms task from Inner - A ---INNER SEQUENCE--- Finished 1000 ms task from Outer - B Processing item Inner - A Starting 2000 ms task from Inner - A ---OUTER LOOP--- Finished 2000 ms task from Inner - A Starting 1000 ms task from Inner - A Finished 1000 ms task from Inner - A ---INNER SEQUENCE---
我也尝试过瀑布，mapSeries等，但是使用相同或其他方式搞砸了执行顺序。 我做错了什么或不是异步模块支持这种嵌套？
你没有调用outerCallback2 ，你没有调用callback outerCallback2 ， outerCallback立即调用outerCallback 。
固定：
async.eachSeries(myarr, function( item, outerCallback) {
,----------------------------------------'
| console.log('Processing item ' + item);
| async.series([
| function(callback) {
| `--------------,
| takeTime(2000, item, callback)
| },
| function(callback) {
| `--------------,
| takeTime(1000, item, callback)
| },
| function(callback) {
| ,-----------'
| | async.eachSeries(myarr2, function( item2, outerCallback2) {
| | ,---------------------------------------------'
| | | console.log('Processing item ' + item2);
| | | async.series([
| | | function(callback2) {
| | | takeTime(2000, item2, callback2)
| | | },
| | | function(callback2) {
| | | takeTime(1000, item2, callback2)
| | | }
| | | ], function(err) {
| | | console.log('---INNER SEQUENCE---')
| | `---> outerCallback2(err); // <<<
| | })
| | }, function(err){
| | console.log("---INNER LOOP---");
| `---> callback(err); // <<<
| });
| }
| ], function(err) {
| console.log("---OUTER SEQUENCE---")
`---> outerCallback(err); // <<<
})
}, function(err){
console.log("---OUTER LOOP---")
console.log("everything done");
});