Obsługa asynchronicznych zapytań do bazy danych w node.js i mongodb

Zanim wyjaśnię dalej, chciałbym zauważyć, że w twoim kodzie jest błąd:

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
}

Problem klasycznych zamknięć i pętli. Zobacz:Proszę wyjaśnij użycie zamknięć JavaScript w pętlach

Teraz, jak obsługiwać funkcje asynchroniczne w pętlach. Podstawową ideą jest to, że musisz śledzić, ile wywołań asynchronicznych zostało zakończonych i uruchomić kod po powrocie ostatniego wywołania. Na przykład:

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

Jednakże, jeśli będziemy to dalej robić, oczywiste jest, że stworzymy mnóstwo zmiennych tymczasowych i skończymy z okropnie zagnieżdżonym kodem. Ale ponieważ jest to JavaScript, możemy zawrzeć logikę tego wzorca w funkcji. Oto moja implementacja tej logiki „czekaj na wszystko, aby ukończyć” w javascript:Koordynacja równoległego wykonywania w node.js

Ale ponieważ używamy node.js, możemy użyć wygodnego modułu asynchronicznego w postaci npm:https://npmjs .org/package/async

Dzięki async możesz napisać swój kod w następujący sposób:

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