Mongooseクエリ（約束）を配列に追加して並列処理を行う

Question

Mongooseを使ってMongoDBで何らかの操作をしています。ユーザーが作成したすべてのタスクを調べて、isPerformingの値をfalseに設定して保存します。 ドキュメントでは、mongooseクエリ（.exec()機能付き）が有望です。多くのタスクがありますので、それらを配列にプッシュして、Q.all([...])を使用して並列保存操作を行うと思います。問題は私が.push()をしようとするときです。私のコードは、最初に.push()操作の後に停止します。 他の方法がありますか？

function stopUserTasks(userid) { 

    var deferred = Q.defer(); 
    var query = Task.find({'_creator': userid}).exec(); 

    query.then(function(data, err) { 
     console.log('found: '); 
     console.log(data); 
     if (err) { 
      deferred.reject(err); 
     } 
     return data; 
     }) 
     .then(function(data, err) { 

     var len = data.length; 
     var saveTasksPromises = []; 

     for(var i = len; i--;) { 
      console.log(data[i]._id); 
      saveTasksPromises.push(Task.save({'_id': data[i]._id, 'isPerforming': false}).exec()); 
     } 
     return saveTasksPromises; 

     }) 
     .then(function(data, err) { 
     console.log(data); 

     deferred.resolve(); 
     }); 

     return deferred.promise; 

    }// #stopUserTasks 

Answer 1

Model.save()戻り、実際に約束ので、あなたの行は次のように調整する必要がModel.save().exec()を記述するので、必要はありません：

saveTasksPromises.push(Task.save({'_id': element._id, 'isPerforming': false})) 

はまたQ.allを使用して、全体の機能は次のように考えられます。

function stopUserTasks(userid) { 
    var deferred = Q.defer(); 
    var promise = Task.find({'_creator': userid}).exec(); 

    promise 
    .then(function(data) { 
     var len = data.length; 
     var saveTasksPromises = []; 

     for(var i = len; i--;) { 
     saveTasksPromises.push(Task.save({'_id': data[i]._id, 'isPerforming': false})); 
     } 
     return Q.all(saveTasksPromises); 
    }) 
    .then(function(data) { 
     deferred.resolve(data); 
    }); 
    .catch(function(err) { 
     deferred.reject(err); 
    }); 
    return deferred.promise; 
}