Node.Js 비동기 사용법

Question

내 Process1() 함수에 데이터베이스 루프가 있으므로 Process2() 및 Process3() 번 이상 호출하는 중입니다. async에 어떤 기능을 사용하여 for loop을 기다려야합니까?

async.waterfall([ 
    function(callback){ 
     Process1(yyy, function(){ 
      //process1 function has a for loop. 
      callback(); 
     }) 
    }, 
    function(callback){ 
     Process2(function(){ 
      // so process2() is calling more than once 
      callback(); 
     }) 
    } 
], function (callback) { 
    Process3() 
}); 

Process1() : 호출이 다시 일어날 때까지 lodash 및 underscore 대기하지 않기 때문에 코드를 보면

function Process1(yyy, pass){ 
user.find({}).exec(function(e, users){ 
    _.each(users, function(_user){ 
     user.findOneAndUpdate(
      {'_id' : user_id}, 
      {$inc : {'xxx' : yyy}}, 
     function(e){ 
      !e && pass() 
     }) 

    }) 
}) 
} 

Answer 1

는 Process2 확실히, 두 번 이상 호출됩니다. 그것들은 단지 유틸리티 방법 일뿐입니다.

asynchronous 상황을 해결하려면 async.each 또는 async.eachSeries을 사용하십시오.

function Process1(yyy, pass){ 
    user.find({}).exec(function(e, users){ 
    async.each(users, function(_user, next){ 
     user.findOneAndUpdate(
      {'_id' : user_id}, 
      {$inc : {'xxx' : yyy}}, 
     function(e){ 
      !e && next() 
     }) 
    }, function(err) { 
     pass(); 
    }) 
    }) 
}