Добрый день!
Пишу бэкенд сервера для работы с кассами.
Стек технологий Java/Spring Boot/MySql
В качестве БД взял MySQL (ибо фронт уже на нем).
По сути сервер должен принимать задания в виде json, а кассы эти задания должны выполнять.
Внутри кассы нет очереди и работают они только в одном потоке, грубо говоря так:



Идея была следующая: храним кассы в таблице devices, задания в таблице tasks.
При старте сервера запускаем столько потоков, сколько девайсов в таблице devices.
Потоки с определенным периодом делают селект из таблицы с заданиями и поочередно их выполняют.
Апи для заданий асинхронное, т.е. снаружи прилетает post запрос, создается запись в таблице tasks и назад клиенту отдается id этого задания.
По id задания клиент может отследить прогресс и результат. (GET /task/{id})

В результате получились следующие классы:
Контроллеры - спринговые @RestControllerы:
DeviceController

TaskController
Модели - стандартные Entity:

Device

Task
Репозитории - спринговые JpaRepository:

DeviceRepository

TaskRepository
Сервис:

DeviceService - спринговый @Service, при инициализации сервис читает из базы список касс и создает на каждую по потоку (экземпляр DeviceWorker) и запускает их.
Worker:

DeviceWorker - собственно класс наследник thread, который получает и задания из базы и работает с кассой.

Каким компонентом спринга должен быть DeviceWorker в данной ситуации, чтобы было удобно инжектить внутрь него репозитории и нормально работали транзакции. Я читал и про спринговые TaskExecutor и про Scheduler, но так и не смог понять как их применить в данной ситуации.
Сейчас я передаю экземпляры репозиториев через конструктор из DeviceService при создании воркеров. Но такое ощущение, что это кривое решение и могут быть проблемы с транзакциями(хотя и работает).
Репозитории внутри воркера нужны для обновления статуса девайса, таска и записи результата выполнения таска.

PetroNotC Sharp,

Асинхронность нужна, т.к. задания могут выполняться неопределенно долго. И если будет 5 одновременных заданий то последний зависнет больше чем на минуту, а это неприемлимо.

PetroNotC Sharp,

Post из фронта прилетает из браузера.

PetroNotC Sharpcapfreedom228PetroNotC Sharp,

Асинхронность нужна, т.к. задания могут выполняться неопределенно долго. И если будет 5 одновременных заданий то последний зависнет больше чемн на минуту, а это неприемлимо.контейнер веб сервера при занятом сервлете запускает новый экземпляр.
Значит 5 вкладок выполнятся вместе за 15 сек.
Проверь

касса в 1 поток работает

chpashacapfreedom228Каким компонентом спринга должен быть DeviceWorker в данной ситуации, чтобы было удобно инжектить внутрь него репозитории и нормально работали транзакции
Я бы попробовал обыкновенный спринговый bean с одним публичным методом и аннотацией Async - почитай про нее. Если кол-во девайсов число постоянное на момент старта, то просто настроить taskexecutor с пулом нужного размера

хотелось иметь возможность добавлять кассы без рестарта

PetroNotC Sharpcapfreedom228,
Не понял.
Касса синглетон или можно сделать
Kassa a = new Kassa(settings);
Kassa б = new Kassa(settings);
?

сделать можно, но когда ты вызовешь a.open(); то b.open(); - выдаст ошибку подключения.

PetroNotC SharpЧтобы касса не простаивала))))))))?

Такое тз

PetroNotC Sharpcapfreedom228выдаст ошибку подключения.то есть нужна асинхронность, но касса категорически однопоточна?
Фиктивная нужна? Зачем?

Чеки электронные и клиенту нет смысла ждать.

Sergunkacapfreedom228пропущено...


хотелось иметь возможность добавлять кассы без рестарта

А параметром номер кассы никак нельзя передать?

В таске зафиксирован id кассы, т.е. каждый таск предназначен конкретной кассе.