Всем привет. Я снова со странными вопросами про асинхронщинну. Хочу как-то

Question

Всем привет. Я снова со странными вопросами про асинхронщинну. Хочу как-то

сделать очередь в асинхронный Promise.all который может например принять только 20 задач, и по мере исполнения промисов принимать новые из очереди или ожидать когда они появятся если пока нет.
Может кому-то знакома реализация чего-то подобного?

#backend #javascript #node.js #programming #russian

0

30.07.2021

10 ответов

17 просмотров

Владимир Наваев

Реализовать самому имхо не проблема и быстрее будет. А зачем такое нужно?

0

30.07.2021

Михаил Ковальчук

promise.all это явно не то, что надо. Тут либо всё выполнится, либо хоть что то одно отклонится и тогда promise.all сделает reject. Объясни для чего тебе это нужно сделать

0

30.07.2021

Айван Автор вопроса

Просто, только его знаю для асинхронно выполнения нескольких функций. Есть ему ещё какие-то альтернативы? Мне это нужно для получения новых апдейтов от апи и асинхронной обработки их. Хочу сделать чтобы если пришло слишком много апдейтов, ограничить количество одновременно исполняемых, но при этом чтобы не приходилось ждать пока все 20 исполнятся чтобы перейти к следующему. То что Promise.all будет ждать всех тоже думал, есть вариант положить туда не сами функции которых хочу дождаться, а "воркеры" у которых будет доступ к списку в которые будут ложиться апдейты Что-то вроде updates = [] workers = [] for (i = 0; i < workerNumber, i++) { workers.push(async () => { for (update of updates) { handleUpdate(update) } } await Promise.all(workers) Тут предполагается что for (update of updates) будет как-то ждать новые апдейты в списке, а не выходить из цикла когда со всеми закончит

0

31.07.2021

Айван Автор вопроса

Понимания node.js маловато (

0

31.07.2021

Joe Beretta

Поизучай тут: https://stackoverflow.com/questions/53540348/js-async-await-tasks-queue Есть годные ответы, если что тебе нужна "очередь" со своими условиями. Чтобы очередь сторонилась через 20 штук и продолжала дальше если меньше 20 стало. Но не забывай обработать кейсы, а что если что-то из очереди эксепшн кинет? Будет ли это -1 как и в обычном случае или все же обратно в очередь, пока не получишь ок? Также можешь очередь свою построить на базе EventEmitter. Профит в таком случае в том, что ты сможешь не только просто в очередь кидать и ждать обработки, но и ивэнты эмитить, что что-то новое пришло в очередь, что что-то вернуло ответ и триггерить или аналогично, если отвалилось что-то, ну и обрабатывать каждый кейс через листенера

0

31.07.2021

Алексей Попов

Это действительно не сложно сделать самостоятельно. Даже полезно сделать самостоятельно Но вообще есть www.npmjs.com/package/p-limit или www.npmjs.com/package/p-queue (и множество других пакетов)

0

31.07.2021

kool jan

В lodash помоему есть подходящие функции

0

31.07.2021

Айван Автор вопроса

Спасибо! p-queue кажется подходящим

0

31.07.2021

˸̧̨ ͅBlack Akula˸̧̨ ͅ ̤ ̬̪

О, блин. А я свою реализацию с нуля делал - даже не знал, что либа есть. У нас каждый микросервис так в очереди деплоится (через child_process). Хотел даже на гитхаб свой велосипед выложить (но руки не доходили)

0

31.07.2021

geroni mo · Accepted Answer

geroni mo

А зачем это делать?

0

30.07.2021

170 похожих чатов

Всем привет. Я снова со странными вопросами про асинхронщинну. Хочу как-то

10 ответов

Похожие вопросы