node.jsでサーバ上でループを実行する

Question

私は常に多くのクライアントからいくつかのデータを収集し、このデータでいくつかのものを解決する複雑なループを並列実行する必要があるとしましょう。どうすればいいですか？私はちょうど、コードの私の作品でこれを書く必要があります。

app.get('/', function(req, res) { 
    res.sendFile(__dirname + '/public/views/index0.html'); 
}); 

io.sockets.on('connection', function(socket) { 
    // SOME STUFF WITH THE SOCKET 
    socket.on('disconnect', function(data) { 
     //SOME OTHER STUFF 
    }); 

}); 

while(...) { 
    //THE LOOP STUFF 
} 

または私がのsetTimeout（）としたsetInterval（）関数を使用する必要がありますか？コールバックのものと並行して動作するサーバー上でループを実行するにはどうすればよいですか？

Answer 1

makeの間は使用しないでください。これはスレッドをブロックします。 setTimeout（）は1回だけ実行されます。 setInterval（）関数を使用する必要があります。

Answer 2

asyncモジュールを使用すると、コールバックで非同期操作を処理したり、コールバックを回避するためにpromiseを使用したりできます。私は各操作の複雑な非同期の処理方法ここで

、あなたのアイデアのhandelingのayncsは何の問題、あなたが実際に解決しようとしている

var cond = { _schedule: schedule_id }; // find curse by schedule id 
Course.find(cond, function (err, courses) { 
    if (err) { 
     callback({ "success": false, "message": "Not able to update" }); 
    } else { 

     async.forEachLimit(courses, 1, function (course, coursesCallback) { 
      async.waterfall([ 
       function (callback) { 
        var schedule_date = moment(change_data.date).format('YYYY-MM-DD') + "T00:00:00.000Z" 
        var Assignmentcond = { 
         assignment_schedule_order: { 
          $gte: schedule_date 
         }, 
         _course: course._id, 
         _schedule: schedule_id, 
         _user: userid 
        }; 

        Assignment.find(Assignmentcond) 
         .populate({ 
          path: '_course', 

         }) 
         .lean() 
         .sort({ assignment_schedule_order: 1 }) 
         .exec(function (err, AssignmentList) { 
          if (err) { 
           callback(null, ''); 
          } else { 
           //console.log("------------------AssignmentList---------------------------"); 
           //console.log(AssignmentList); 

           async.forEachLimit(AssignmentList, 1, function (ThisAssignmentCell, ThisAssignmentCellCallback) { 

            async.waterfall([ 
             function (callback) { 
              var SearchObj = items; 
              var lebelObject = {}; 

              for (var i = 0, flag = 0, insert = 0; i < SearchObj.length; i++) { 

               if (SearchObj[i].date == ThisAssignmentCell.assignment_schedule_date) { 
                flag = 1; 
               } 
               if (flag == 1 && SearchObj[i].label != "") { 
                if (ThisAssignmentCell.day == SearchObj[i].day_index) { 
                 insert = 1; 
                 var lebelObject = SearchObj[i]; 
                 break; 

                } 

               } 

              } 




              callback(null, ThisAssignmentCell, lebelObject, insert); 
             }, 
             function (ThisAssignmentCell, SearchObj, insert, callback) { 
              console.log('----------------------'); 
              console.log('ThisAssignmentCell', ThisAssignmentCell); 
              console.log('SearchObj', SearchObj); 
              console.log('----------------------'); 

              if (insert > 0) { 

               var query = { _id: ThisAssignmentCell._id }, 
                fields = { 
                 assignment_date: moment(SearchObj.date).format('MM/DD/YYYY'), 
                 assignment_schedule_date: moment(SearchObj.date).format('YYYY-MM-DD'), 
                 assignment_schedule_order: new Date(SearchObj.date), 
                 day: SearchObj.day_index, 
                 dayNum: SearchObj.weekday_num 
                }, 
                options = { upsert: false }; 

               Assignment.update(query, fields, options, function (err, affected) { 
                callback(null, ''); 
               }); 


              } else { 
               //                         var cond = { _id: ThisAssignmentCell._id}; 
               //                         Assignment.remove(cond) 
               //                           .exec(function (err, cnt) { 
               //                            callback(null, ''); 
               //                         }); 

              } 



             } 
            ], function (err, result) { 
             // result now equals 'done' 
             console.log('done') 
             ThisAssignmentCellCallback(); 
            }); 


           }, function (err) { 
            console.log("Assignment For Loop Completed"); 
            callback(null, AssignmentList); 
           }); 



          } 
         }); 



       } 
      ], function (err, result) { 
       // result now equals 'done' 
       console.log('done') 
       coursesCallback(); 
      }); 
     }, function (err) { 
      console.log("courses For Loop Completed"); 
     }); 

    } 
});