rs.readFile in async.series Sequencing-Problem

Question

Klar mache ich hier etwas falsch, aber ich sehe es nicht.

Ich habe meinen Code reduziert, um das Problem zu illustrieren, das ich habe.

Mit async.series Ich verarbeite eine Reihe von Dateien. Für jede Datei lese ich es und mache etwas mit dem Inhalt und gehe weiter. Wenn ich den readFile Aufruf von readFileSync ändere, bekomme ich die erwartete Ausgabe, aber das ist keine Lösung, die hier aus einer Vielzahl anderer Gründe funktionieren wird.

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(); 
    }); 
} 

Was ich erwarte, wenn ich die oben ausgeführt ist:

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

Aber was ich bekommen ist

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

Was mache ich falsch?

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(); 
 
    }); 
 
}