Как отменять таски, которые уже в очереди?

Question

[wawa]

Сервис А создает таски для сервиса Б, который их выполняет и возвращает результат обратно на сервис А. Работает это на очередях. В любой момент времени сервис А может решить, что некоторые уже отправленные к Б таски протухли и не нужно их выполнять. Но они уже в очереди в перемешку с актуальными тасками. Как разумней/проще сделать так, чтобы сервис Б игнорил такие таски и не тратил на них ресурсы? Наверняка есть какой-то более-менее общепринятый подход.

Answer 1

[Dimonchik]

любой таск добавленный в очередь имеет ID

Comments

[wawa]

dimonchik2013 ок. снабдил я айдишником каждый таск. но он уже в очереди (rabbit например), как теперь изъять его оттуда?

[yayashitoya]

wawa,

ок. снабдил я айдишником каждый таск. но он уже в очереди (rabbit например), как теперь изъять его оттуда?

"не RabbitMQ, как например".
А конкретно у RabbitMQ конкретное API.

[Dimonchik]

(rabbit например)

это уже второй вопрос
впрочем, все опен сорс, и вы можете дописать, если там нет такой фичи ))))))))))

[wawa]

dimonchik2013, ну это не серьезно.
Мне нужно решение без допиливания существующих технологиях.
Вообще идея есть, но боюсь велосипед изобрести.

[Dimonchik]

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

во-вторых, AMQP, хоть и посложнее

перед чисткой можно перемешать таски, и т.д. и т.п.

[wawa]

dimonchik2013, если чистить очередь, то потеряются и актуальные таски. Хотя может я вас не правильно понял - можно объяснить?

Answer 2

[Иван Шумов]

Да никак. В очереди должны быть только сообщения, требующие обработки. Не для того вы из используете. Если так удобнее надо вам это делать то добавьте хранилище с блокировками и если оно там то сообщение должно быть проигнорировано, а метка из блокировки стерта