Как реализовать очередь в node js?

Question

[Meefril]

Каким образом было бы правильнее сделать очередь?
Юзер отправляет запрос(видео) на боту -> Сервер это видео обрабатывает(Он может обрабатывать только 1 видео за раз и преступает к следующему лишь тогда, когда завершил предыдущее) -> Отправляет измененное видео юзеру

Сейчас я сделал так:

Создал массив queue, что состоит из объектов { task_data, user_id }
Создал флажок is_working

Асинхронная функция editVideo запускается каждую секунду через setInterval. Внутри неё

if(queue.length > 0 && !flag_working){
        flag_working = true
        data = queue.shift()
        ...working....
        sendEditedVideo()
       flag_working = false
}

Как правильнее было бы реализовать это?

Answer 1

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

Как правильнее было бы реализовать это?

Не изобретать велосипед, а погуглить готовые решения для очередей.
Беглый поиск:
https://www.npmjs.com/package/queue
https://github.com/bee-queue/bee-queue
https://levelup.gitconnected.com/how-to-implement-...
Ну и всякие там rabbitmq и т.п.

Comments

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

если ответ помог, то можете пометить решением )) Это лучшее спасибо на этом ресурсе.

Answer 2

[mayton2019]

Если в стеке технологий у вас стоит Redis - то можно его использовать для очереди
https://redis.com/redis-best-practices/communicati...

Answer 3

[Mikhail Osher]

https://github.com/OptimalBits/bull
https://optimalbits.github.io/bull/

Используйте это или посмотрите, как реализована библиотека.