Дано:
- REST сервис-калькулятор, который обсчитывает задачи.
- Конечный сервис, который инициирует расчет задач и обрабатывает результат.
Для расчета задачи вызывается метод этого сервиса. Как только задача посчиталась сервис-калькулятор вызывает метод конечного сервиса и передает результат.
Как лучше организовать архитектуру конечного сервиса?
Я придумал следующую схему:
- Шлем запрос, кладем в ConcurrentHashMap по id задачи объект который содержит запрос/ответ
- Задача обсчиталась - вызвался метод конечного сервиса
- По id задачи лезу в мапу, записываю ответ, передаю на обработку
- Удаляю из мапы
Вроде рабочая схема, но возникает проблема: как удалять задачи, которые не обсчитались за определенное время? Сделать по шедулеру очистку от зависших задач?