Мне необходимо создать несколько сервисов в которых будут крутится бесконечные циклы, с возможностью их остановки. Вроде как напрашивается реализовать все в отдельных потоках. Я попробовал создать их в приложении на Spring, написав небольшое тестовое приложение. Использование Spring в данном приложении обусловлено тем, что придется подключать к нему web-интерфейс. Используется встроенный веб-сервер Apache Tomcat.
@Service
public class FirstService
public isStart = false;
private action() {
while (isStart) {
...
}
}
}
@Service
public class NextService
public isStart = false;
private action() {
while (isStart) {
...
}
}
}
Запуск и остановку сервиса осуществляю через контроллеры
@RestController
public class MyController {
FirstService firstService;
@PostMapping
public ResponseEntity<?> post(@PathVariable(PARAM_ACTION) Integer action) {
firstService.isStart = ...;
...
}
...
}
Вроде как все работает, т.е. получается, что приложение многопоточное? Иначе бы все останавливалось, пока не будет выполнен первый же метод action Вопрос: стоит ли мне создавать многопоточное приложение, если все и так работает? Или это не очень хорошее решение и все-таки надо реализовывать используя стандартное решение с потоками? Или может у Spring есть другое готовое решение и для таких случаев?
Хотелось бы использовать для решения этой задачи что-то готовое от Spring. Но я не знаю какой из его компонентов может мне в этом помочь. Основное требование это быстродействие, время цикла не должно превышать 20мсек, т.е. это должны быть не очень тяжелые компоненты. В каждой итерации цикла выполняется прием от 300 до 800 байт данных по изернету, обработка их и отправка по другому адресу. И таких сервисов может быть от трех до пяти одновременно. Если у Spring есть компоненты, которые справятся с такой задачей, то буду рад если подскажите их названия, а я уже займусь их изучением. Другими словами мне нужен совет в каком направлении копать, юзать какой-то компонент от Spring или начинать изучать многопоточные приложения и создавать свой компонент.
По сети (ETH) происходит прием массива байтов (300-800 байт), они могут приходить с двух или трех каналов, обработка заключается в переводе этих байтов в физические величины для вывода на фронт (REST API) и формирования новых массивов байт из полученного набора для передачи уже по одну - двум каналам. Циклы приема-передачи должны иметь возможность запускаться по сигналу с фронта и так же останавливаться, с возможностью остановки каждого в отдельности. Частота приема-передачи по каждому каналу 20-100мс
firstService.action
. Если из контроллера, то это плохо, так как вы занимаете потоки из пула обработки http запросов. Правильно их вызывать в фоне используя TaskExecutor явно или используя @Async. И еще у вас проблема с корректной остановкой см. ru.stackoverflow.com/q/1302473/218971