Manipulando consultas de banco de dados assíncronas em node.js e mongodb

Antes de explicar mais, gostaria de observar que há um bug no seu código:

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
}

Problema clássico de fechamentos e laços. Consulte:Por favor explicar o uso de closures JavaScript em loops

Agora, como lidar com funções assíncronas em loops. A ideia básica é que você precisa acompanhar quantas chamadas assíncronas foram concluídas e executar seu código assim que a chamada final retornar. Por exemplo:

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

No entanto, se continuarmos fazendo isso, é óbvio que acabaremos criando um monte de variáveis temporárias e acabaremos com um código horrivelmente aninhado. Mas sendo javascript, podemos encapsular a lógica desse padrão em uma função. Aqui está minha implementação desta lógica "wait-for-all-to-complete" em javascript:Coordenando a execução paralela em node.js

Mas, como estamos usando o node.js, podemos usar o conveniente formulário de módulo assíncrono npm:https://npmjs .org/package/async

Com async, você pode escrever seu código assim:

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