async queue를 활용한 분산 처리

async_queue.js

const async = require('async');

// 워커 함수
function worker(data) {
  console.log(data);
}

// 큐 생성
let queue = async.queue(function(data, cb) { 
   worker(data);
   cb();
}, 10);

// 완료시 종료
queue.drain = function () {
    logger.info("queue is drain");
    process.exit(0)
};

// 큐에 값 넣기
queue.push(["helle", "world"]);