Асинхронный цикл JavaScript & Генераторы?

Question

[carroll]

Привет!
Использую фреймворка AdonisJS, методы контроллеров которого выступают функции-генераторы.
Есть код:

* tasks() {
    let tasks = yield Task.findBy('status', 1)

    for(let task of tasks) {
      yield this.task(task)
    }
  }

Необходимо сделать так, чтобы содержимое цикла не выполняла this.task синхронно, а запустила по циклу параллельно. Вопрос - КАК?

Comments

[Алексей Ярков]

Так?

function bind(func, context) {
  return function() {
    return func.apply(context, arguments);
  };
}

* tasks() {
    let tasks = yield Task.findBy('status', 1)

    for(let task of tasks) {
      setTimeout(bind(task(task), this), 0);
    }
  }

[carroll]

Алексей Ярков: содержимое функции this.task() в таком случае НЕ выполняется :(

[Алексей Ярков]

carroll: с контекстом поиграйте

Answer 1

[Дмитрий Беляев]

Если в основе фреймворка под генераторами лежат промисы, то есть идет имитация async/await, то должно помочь так:

* tasks() {
    let tasks = yield Task.findBy('status', 1)

    let promises = []
    for(let task of tasks) {
      promises.push(this.task(task))
    }
    yield Promise.all(promises)
  }

Comments

[Islam Ibakaev]

это ассинхронный вариант, такой же как и этот

function* tasks() {
  let tasks = yield Task.findBy('status', 1);
    
  for(let task of tasks) {
    setTimeout(this.task(task).bind(this), 0);
  }
}

p.s. Алексей Ярков уже предложил выше(просто заморочился с функцией bind)

[Дмитрий Беляев]

Islam Ibakaev: не совсем, мой вариант запустит таски "параллельно", но будет ждать их всех, этот ждать не будет вообще

[carroll]

Дмитрий Беляев: вы - гений. Спасибо!

[Islam Ibakaev]

Дмитрий Беляев:
это то же самое что написал и я
вы не запускаете таски параллельно, вы запускаете их ассинхронно
чтобы выполнить параллельно в ноде - https://nodejs.org/api/cluster.html

p.s. но я так понимаю, что автор вопроса всё-таки хотел ассинхронность, хоть и писал про параллельное выполнение.

Answer 2

[Islam Ibakaev]

javascript - это single-thread language. ты не вызовешь параллельно this.task(task) для всех элементов массива. ассинхронность не значит, что код выполняется параллельно, он просто выполняется в non-blocking стиле. даже promise.all() не выполняется параллельно. чтобы выполнить код параллельно - нужно выполнить его в отдельном потоке(webworkers).

Comments

[carroll]

Это 100% информация??

[Islam Ibakaev]

carroll: be sure

[carroll]

Islam Ibakaev: Ну есть он выполняется в non-blocking стиле, то почему каждый this.task() блокирует следующий до окончания выполнения? И как переходить к следующему this.task() без окончания выполнения предыдущего?

[Islam Ibakaev]

carroll: ну видимо потому что this.task это ассинхронная операция, которую ты выполняешь синхронно, поэтому и приходиться ждать

[Islam Ibakaev]

carroll: покажи метод this.task

[Islam Ibakaev]

ты не сможешь перейти к другому таску пока выполняется один, поскольку, как я уже говорил, джаваскрипт - однопоточный. Чтобы заранить второй таск паралльно первому, тебе необходимо открыть его в отдельном потоке. Чтобы заранить все таски, для каждого(насколько я знаю) придётся выполнять в отдельном потоке. Короче целая суета. Делай по очереди.

p.s. но если ты не из тех кто сдаётся начни отсюда

[Дмитрий Беляев]

Islam Ibakaev: не пудрите человеку мозг! какие веб-воркеры на ноде? отдельные процессы еще может быть, но смысла тут нет, сама суть асинхронности в том, что ядро ОС и так работает в отдельном потоке (даже в нескольких), и его можно не ждать (особенно когда ОС при этом работает с железом)

[Islam Ibakaev]

Дмитрий Беляев: я не говорил о веб-воркерах на ноде(я говорил о нём как о возможности выпонить скрипт параллельно, в отдельном потоке).
плюс то что вы написали про ассинхронность, не противоречит тому, что я написал.
так что не надо говорить, что я пудрю мозг.