Zpracování asynchronních databázových dotazů v node.js a mongodb

Než to vysvětlím dále, rád bych poznamenal, že ve vašem kódu je chyba:

function(err_positive, result_positive) {
    result_positive.count(function(err, count){
        console.log("Total matches: " + count);
        positives[i] = count;  // <--- BUG: i id always 5 because it
    });                        //           is captured in a closure
}

Problém s klasickými uzávěry a smyčkami. Viz:Prosím vysvětlit použití uzávěrů JavaScriptu ve smyčkách

Nyní, jak zacházet s asynchronními funkcemi ve smyčkách. Základní myšlenkou je, že musíte sledovat, kolik asynchronních volání bylo dokončeno, a spustit kód, jakmile se vrátí poslední volání. Například:

var END=5;
var counter=end;
for (var i=0;i<END; i++) {
  collection.find(
    {value:1},
    {created_on: 
      {       
        $gte:startTime + (i*60*1000 - 30*1000),
        $lt: startTime + (i*60*1000 + 30*1000)
      }
    },
    (function(j){
      return function(err_positive, result_positive) {
        result_positive.count(function(err, count){
            console.log("Total matches: " + count);
            positives[j] = count;
        });

        counter--;
        if (!counter) {
          /*
           * Last result, now we have all positives.
           *
           * Add code that need to process the result here.
           *
           */
        }
      }
    })(i)
  ); 
}

Pokud to však budeme dělat dál, je zřejmé, že nakonec vytvoříme spoustu dočasných proměnných a skončíme s příšerně vnořeným kódem. Ale protože je to javascript, můžeme logiku tohoto vzoru zapouzdřit do funkce. Zde je moje implementace této logiky "wait-for-all-to-complete" v javascriptu:Koordinace paralelního provádění v node.js

Ale protože používáme node.js, můžeme použít pohodlný asynchronní modul ve formě npm:https://npmjs .org/package/async

S async můžete napsat svůj kód takto:

var queries = [];

// Build up queries:
for (var i=0;i <5; i++) {
  queries.push((function(j){
    return function(callback) {
      collection.find(
        {value:1},
        {created_on: 
          {       
            $gte:startTime + (j*60*1000 - 30*1000),
            $lt: startTime + (j*60*1000 + 30*1000)
          }
        },
        function(err_positive, result_positive) {
          result_positive.count(function(err, count){
            console.log("Total matches: " + count);
            positives[j] = count;          
            callback();
          });
        }

      );
    }
  })(i));
  queries.push((function(j){
    return function(callback) {
      collection.find(
        {value:0},
        {created_on: 
          {
            $gte:startTime + (j*60*1000 - 30*1000),
            $lt: startTime + (j*60*1000 + 30*1000)
          }
        },
        function(err_negative, result_negative) {
          result_negative.count(function(err, count){
            console.log("Total matches: " + count);
            negatives[j] = count;
            callback();
          });
        }   
      );
    }
  })(i));  
}

// Now execute the queries:
async.parallel(queries, function(){
  // This function executes after all the queries have returned
  // So we have access to the completed positives and negatives:

  // For example, we can dump the arrays in Firebug:
  console.log(positives,negatives);
});