rs.readFile в async.series проблема секвенирования

Question

Очевидно, что я делаю что-то неправильно здесь, но я этого не вижу.

Я уменьшил свой код до нижнего, чтобы проиллюстрировать проблему, которую я имею.

Использование async.series Я обрабатываю набор файлов. для каждого файла я читал его и делал что-то с содержимым и двигался дальше. Если я изменю вызов readFile на readFileSync, я получаю ожидаемый результат, но это не решение, которое будет работать здесь по ряду других причин.

var fs = require('fs'); 
var async = require('async'); 

huh(); 

function huh() { 
    for (var i in [1,2]) { 
     async.series([ 
       function (callback) { process('a', callback); }, 
       function (callback) { process('b', callback); } 
      ], function() { console.log('series done')}); 
     console.log('done: ' + i); 
    } 
} 

function process(word, callback){ 
    fs.readFile('whatever', function (err, content) { 
     console.log(word); 
     callback(); 
    }); 
} 

Что ожидать, когда я бегу выше:

a 
b 
series done 
done: 0 
a 
b 
series done 
done: 1 

Но то, что я получаю

done: 0 
done: 1 
a 
a 
b 
series done 
b 
series done 

Что я делаю неправильно?

Answer 1

var fs = require('fs'); 
 
var async = require('async'); 
 

 
huh(); 
 

 
function huh() { 
 
    var queue = []; 
 
    for (var i in [1, 2]) { 
 
    (function(tmpi) { 
 
     queue.push(function(callback) { 
 
     process('a', callback); 
 
     }); 
 
     queue.push(function(callback) { 
 
     process('b', callback); 
 
     }); 
 
     queue.push(function(callback) { 
 
     console.log('series done'); 
 
     callback() 
 
     }); 
 
     queue.push(function(callback) { 
 
     console.log('done: ' + tmpi); 
 
     callback() 
 
     }); 
 

 
    })(i); 
 

 

 

 

 
    } 
 
    async.series(queue, function() { 
 
    console.log('all done!') 
 
    }); 
 

 
} 
 

 
function process(word, callback) { 
 
    fs.readFile('whatever', function(err, content) { 
 
    console.log(word); 
 
    callback(); 
 
    }); 
 
}