Nodejs async.each最初のループを待つ

Question

rowsArr（100レコードと言う）を非同期で処理しようとしていますが、データベース接続を避けるためにデータベースから国リストを一度だけ読み込みたいとします。私は下のコード例を試していますが、データベース接続を100回開いています。

var countryList = null; 

async.each(rowsArr, function(row, callback) { 


    if(countryList == null) 
    { 
     console.log("open database here to get country list and then assign to below variable"); 

     countryList = countriesFromDatabase; 

     callback(countryList); 
    } 
    else 
    { 
     callback(countryList); 
    } 


}, function(err){ 

     console.log("all rows are processed"); 

}); 

それは、async.eachSeriesで正常に動作しているが、私は非同期にそれをしたいです。なにか提案を？

Answer 1

1. すべての行

だから、次のプロセスが

function getCountries(callback) { 
    console.log("open database here to get country list and then assign to below variable"); 
    callback(null,countriesFromDatabase); 
} 
getCountries(function(err, countriesFromDatabase) { 
// use countries in following async loop 
    async.each(rowsArr, function(row, callback) { 
    callback(null, row); //process row here 
    }, function(err) { 
    console.log("all rows are processed"); 
    }); 
}); 

Answer 2

に動作しますデータベース

から国をゲットそれは実際に、すべての百の行が同時に開始を処理すべきかを行い、 ifブロックを通過しています。

ロックを使用するとよいでしょう。 https://github.com/BorisKozo/node-async-locks

このように、複数のデータベース接続を避けるために、あなたのcountryListチェックプロセスをロックすることができます。