Как контролировать число одновременных вызовов асинхронных функций в очереди?

Question

[DarthJS]

Суть такая, не получается контролировать очередь с указанным параметром. Ниже я пихаю колбеки в очередь queue, по которой могу пройтись либо циклом, либо просто использовать Resolve.all, но когда присутствует параметр, например нужно выполнять не больше двух-трех функци, то не получается дождаться.

Допустим есть асинхронная функция и конструктор:

function asynRequest(result) {  // наша асинхронная функция
     setTimeout(result, 2000, 'data');
}

function Foo (params) { // наш конструктор
this.count = params.count // число одновременных вызовов
this.queue = []; // наша будущая очередь
this.working = 0; // параметр, который говорит сколько функций обрабатывается
}

Foo.prototype.tick = function (callback) {
      this.queue.push(callback); // добавляем 
      return this;
}

Foo.prototype.resolver = function () {
    var vm = this;
     this.queue.forEach(function (cb) {  // Тут что бы я не делал у меня выходит либо Max call stack либо просто не 
     получается вернуть проми с результатами. 
     vm.working++;
     });
     return Promise.resolve();
}

Foo.prototype.finish = function () {
       this.resolver().then(function (response) {
       console.log('УРААА!!', response)
       });
}

var executor = new Foo({count: 2});
executor
 .tick()
 .tick()
 .tick()
 .finish()

Я так понимаю, что я пытаюсь использовать неправильный подход. Может для решения данной задачи есть паттерны, которые найти у меня не получилось.

Comments

[Антон Спирин]

Не понятно, что вы именно хотите сделать. Что с результатами? Вы хотите копить массив результатов и передавать его в finish? Или как-то по-другому реализовать?

[DarthJS]

Антон Спирин, не совсем, обратите внимания, 3 вызова tick(), их в теории может быть больше, они все добавятся в очередь, и соответственно в цикле будут отрабатываться поочередно, но в зависимости от таймаута. Так вот, я хочу, чтоб одновременно отрабатывалось не больше, например, двух функции. То есть все в очереди, из очереди отрабатываются 2 функции, как только одна отработала, место освобождается и запускается новая функция из очереди итд. Я предполагаю, что может быть како-то паттерн для данного события, но я к сожалению не нашел.
И результат будет массив результатов всех функций. То есть типа всё просто, но с условием, что одновременно работаю не большу двух, остальные в очереди ожидания, как в паспортном столе

Answer 1

[Антон Спирин]

function Parallel(settings) {
  this.parallelJobs = settings.parallelJobs;
  this.results;
  this.tasks = [];
  this.onDone;
  this.index = 0;
  this.activeJobs = 0;
};

Parallel.prototype.start = function() {
  this.results = Array(this.tasks.length);

  for (var i = 0; i < Math.min(this.parallelJobs, this.tasks.length); i++) {
    this.next();
  }
}

Parallel.prototype.next = function(result) {
  var index = this.index;
  this.activeJobs++;


  this.tasks[this.index](function(result) {
    this.onResult(result, index);
  }.bind(this));

  this.index++;
}

Parallel.prototype.onResult = function(result, index) {
  this.results[index] = result;
  this.activeJobs--;

  if(this.tasks[this.index]) {
    this.next();
  } else if (this.activeJobs === 0) {
    this.onDone(this.results);
  }
}

Parallel.prototype.job = function (step) {
  this.tasks.push(step);
  return this;
};

Parallel.prototype.done = function (onDone) {
  this.onDone = onDone;
  this.start();
};



function asyncRequest1(result) {  
     setTimeout(result, 2000, 'data');
}

function asyncRequest2(result) {  
     setTimeout(result, 2000, 'data 2');
}

function asyncRequest3(result) {  
     setTimeout(result, 2000, 'data3');
}

function asynRequest4(result) {  
     setTimeout(result, 2000, 'data4');
}



var runner = new Parallel({
  parallelJobs: 2
});

runner.job(asyncRequest1)
      .job(asyncRequest2)
      .job(asyncRequest3)
      .job(asyncRequest4)
      .done(function (results) {
         console.log(results); 
      });

Comments

[DarthJS]

Огромное спасибо. Подскажите пожалуйста, это какой-то паттерн для выполнения подобных задач? Если да, как он называется, чтоб я мог более углубленно почитать? Вы попереименовывали функции, вам так удобно или это какой-то образец шаблон?

[Антон Спирин]

DarthJS, похожую задачу помогал делать тут же. Видимо какая-то университетская задачка. Если честно, не знаю называется ли как-то паттерн с очередью, но это известная штука. Вот вам же с промисами советовал Как правильно дождаться результата асинхронных функций в цепочке вызовов?

[DarthJS]

Это та же задачка, просто думал делать через промисы, но хуже обьяснил чем в этот раз :) и не стал уточнять.
В любом случае огромнео спасибо, будем разбираться :)