Promise.all での大量の並行処理を安定させる - Qiita

var Q = require('q'); /** * @param {Function} task 何度も実行したい処理を関数で渡します * @param {Array} pool task に渡す引数を配列で渡します * @param {number} concurrent 同時にタスクを実行する数を指定します * @return {Object} pool が全て消化されたことを示す promise を返します */ function doConcurrent(task, pool, concurrent) { var workers = []; var results = []; var needle = 0; while (workers.length < concurrent) { workers.push(Q.invoke(workIfAny)); } return Q.al