MM
шта?
Size: a a a
2020 November 23
ЛZ
Вот пример асинхронного распараллеливания с помощью очереди
MM
Вот пример асинхронного распараллеливания с помощью очереди
чего-чего, пардон?
A
Ну вот ты положил в rabbitMq задачу 1. Как ты получишь ответ адекватный 2.как быть увереным что она выполнится
MM
Ну вот ты положил в rabbitMq задачу 1. Как ты получишь ответ адекватный 2.как быть увереным что она выполнится
никак
ЛZ
Ну вот ты положил в rabbitMq задачу 1. Как ты получишь ответ адекватный 2.как быть увереным что она выполнится
В редисе это легко решается
ЛZ
У меня очереди с мгновенным получением результата
ЛZ
igbinary-serialized объект бегает через rpush / blpop
АС
Ну вот ты положил в rabbitMq задачу 1. Как ты получишь ответ адекватный 2.как быть увереным что она выполнится
никак
это следует из самого принципа отложенного исполнения
отложил? молодец
есть гарантия, что исполнится? нет
это следует из самого принципа отложенного исполнения
отложил? молодец
есть гарантия, что исполнится? нет
ЛZ
TaskCollection::wait() делает blpop сразу многих ключей
A
TaskCollection::wait() делает blpop сразу многих ключей
Гарантия что адеватно отработает а не выйдет погулять
АГ
если ты собираешься в скрипте, который пушнул джобу, дожидаться, когда она выполнится, то зачем вообще джобы тебе?
ЛZ
Гарантия что адеватно отработает а не выйдет погулять
Для этого есть zset отдельный ;)))
АГ
Гарантия что адеватно отработает а не выйдет погулять
код обработки джобы надо написать так, чтобы не падало
ЛZ
Если за определенный таймаут таска не выполнилась — будет перезапущена
ЛZ
В процессе выполнения таски этот таймаут можно продлять
A
Если за определенный таймаут таска не выполнилась — будет перезапущена
и процесс просто стоит и курит пока джоба работает потомучто ему надо ждать
АГ
Если за определенный таймаут таска не выполнилась — будет перезапущена
это можно через доп. инфу о джобах сделать
ЛZ
и процесс просто стоит и курит пока джоба работает потомучто ему надо ждать
Какой именно процесс? Инициатор?