Телеграмм чат группы nodejs

Size: a a a

Node.js — русскоговорящее сообщество

7749 membersпожаловаться на группу

2021 February 12

Nikita in Node.js — русскоговорящее сообщество

Artem Soroka

очередь

это я понял, имею ввиду что за реализация)

источник

16:51пожаловаться #1

Aleksey Chipiga in Node.js — русскоговорящее сообщество

Mikhail Smolnikov

Снова я.
Пытаюсь разобраться с ассинхронностью.
Нужно: создать пул задач, после прохождения которого запустить одну функцию.
Звучит просто, а на деле я что-то не догоняю.
В гисте вроде всё в комментах расписал, надеюсь понятно будет
Спасибо

Gist

parser

GitHub Gist: instantly share code, notes, and snippets.

Из-за того что queue.add не дожидаешься сразу return callback идёт. История как если .map передать асинхронную функцию

источник

16:51пожаловаться #2

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Aleksey Chipiga

Из-за того что queue.add не дожидаешься сразу return callback идёт. История как если .map передать асинхронную функцию

обернуть queue.add в async?

источник

16:52пожаловаться #3

Alexey Ermakov in Node.js — русскоговорящее сообщество

ну, т.е. смесь эвэйтов с then-ами норм

источник

16:53пожаловаться #4

Aleksey Chipiga in Node.js — русскоговорящее сообщество

Mikhail Smolnikov

обернуть queue.add в async?

Глянуть что он вообще возвращает. Если и так промис вернулся то тогда просто await. Если нет то да, что-то похожее на это

источник

16:53пожаловаться #5

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

В либе еще есть функция queue.on('idle', foo()), которая выполняется, когда пул будет пустым

источник

16:53пожаловаться #6

Draft in Node.js — русскоговорящее сообщество

Шалом! Пытаюсь профайлить проект, и профайлер выдает такую инфу
Что это значит? Типа процесс ноды занимает ~80% процессорного времени. Почему? Зачем?

источник

16:54пожаловаться #7

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Alexey Ermakov

ну, т.е. смесь эвэйтов с then-ами норм

const bar = await foo()
foo().then(bar => ?)
Одно и тоже?

источник

16:55пожаловаться #8

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Или ты про что-то другое?)

источник

16:56пожаловаться #9

Alexey Ermakov in Node.js — русскоговорящее сообщество

Mikhail Smolnikov

const bar = await foo()
foo().then(bar => ?)
Одно и тоже?

типа того

источник

16:56пожаловаться #10

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Aleksey Chipiga

queue.add возвращает promise
но если добавить перед этим await, задачи идут одна за другой

источник

17:00пожаловаться #11

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Видимо цикл не идёт дальше, пока promise от add не вернет что-то

источник

17:02пожаловаться #12

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Хотя, это же бред. По-сути async функция не должна блокировать основной поток

источник

17:02пожаловаться #13

Alexey Ermakov in Node.js — русскоговорящее сообщество

так тебе промисы очередь складывать надо?

источник

17:03пожаловаться #14

Igor in Node.js — русскоговорящее сообщество

Mikhail Smolnikov

Хотя, это же бред. По-сути async функция не должна блокировать основной поток

но ведь нода однопоточная

источник

17:04пожаловаться #15

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Alexey Ermakov

так тебе промисы очередь складывать надо?

либа за меня это и делает
создаётся пул как будто array с промисами внутри
а потом вызывается Promise.All()
Только там ещё чуток магии с количеством потоков, стейтами, но в целом всё

источник

17:06пожаловаться #16

Mikhail Smolnikov in Node.js — русскоговорящее сообщество

Igor

но ведь нода однопоточная

первоначально - да, но с 11.5, если не вру, завезли мультипоток

источник

17:06пожаловаться #17

Alexey Ermakov in Node.js — русскоговорящее сообщество

Mikhail Smolnikov

в смысле либа это делает
там же очередь
что запихнешь туда, то и будет

источник