Как правильно запускать асинхронный метод внутри сервиса?

Question

[nuclear_kote]

Есть сервис например такой:

@Service
public class SomeService {
     ...
     private void asyncMethod() {
           while(true) {
               ....
               queue.poll();
              ....
          }
     }
     ....
}

как правильно запустить asyncMethod в отдельном потоке после инициализации сервиса ?
Есть вариант кроме new Thread(this::asyncMethod).start() ?

Comments

[Сергей Горностаев]

Какое назначение метода? А то бесконечный цикл выглядит как костыль и наводит на размышления, что есть более правильный и изящный способ добиться той же функциональности.

[nuclear_kote]

Сергей Горностаев, обработка очереди

[Сергей Горностаев]

nuclear_kote, лаконично. У Spring'а есть целая куча механизмов для выполнения фоновых задач. Желание запускать потоки низкоуровневым API - признак неправильного использования Spring. Впрочем, как и бесконечные циклы.

[nuclear_kote]

Сергей Горностаев, ну так а я что спрашиваю?

[Сергей Горностаев]

nuclear_kote, как раз пытаюсь разобраться, что вы спрашиваете. Задача "обработка очереди" настолько общая, что невозможно дать ответа точнее. Опишите точнее, что за очередь, откуда берётся, для чего служит и прочее.

[nuclear_kote]

Сергей Горностаев, ну как пример задачи : есть сервис в который кладем данные для сохранения в базу. кладется оно в блокирующую очередь и потом в отдельном потоке из этой очереди идет считывание и сохранение в базу.

[Сергей Горностаев]

nuclear_kote, чтобы ответить клиенту быстрее, чем данные сохранятся?

[nuclear_kote]

Сергей Горностаев, ну как вариант

[Сергей Горностаев]

nuclear_kote, для этой цели я бы объявил в классе сервиса метод, сохраняющий переданные ему данные в базу, и пометил бы его аннотацией @Async. И всё, очередь не нужна, бесконечный цикл тоже. Достаточно в контроллере вызывать этот метод, а Spring сам выполнит его в отдельном потоке, взятом из пула.

[nuclear_kote]

Сергей Горностаев, ну в этом примере согласен, так прокатит. Другой пример: есть библиотека jpcap которая слушает пакеты трафика (сниффер). Написана она криво но тем не менее работа с ней идет примерно так:

while(true) {
     Packet p =  deviceListener.getPacket();
     if (p == null) {
          continue;
     }
     processPacket(p);
}
...

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

[Сергей Горностаев]

nuclear_kote, и что потому нужно делать с полученными пакетами? Складировать в базу для долгосрочного хранения и обработки? Выводить пользователю при следующем запросе? Выводить в реалтайме через удерживаемое открытым соединение websocket?

[nuclear_kote]

Сергей Горностаев, ну например получать данные с них и сохранять в базу

[Сергей Горностаев]

nuclear_kote, тогда лучше сделать совсем это отдельным процессом использующим ту же базу.

[nuclear_kote]

Сергей Горностаев, ну это асинхронность спринга не убирает

[Сергей Горностаев]

nuclear_kote, это будет уже не спринг. Один процесс слушает сеть и пишет результат в базу. Другой, уже Spring MVC процесс, при запросах из базы читает. Поверьте - это самый надёжный, производительный и простой способ.

[nuclear_kote]

Сергей Горностаев, а при чем здесь mvc? И сервисы которые слушают трафик на спрингах чтоли не пишутся?

[Сергей Горностаев]

nuclear_kote, хм, я с чего-то решил, что у вас web-приложение. Это не так?

[nuclear_kote]

Сергей Горностаев, нет

[Сергей Горностаев]

nuclear_kote, майн готт, шедеврально ступил! Ну, в таком случае никаких проблем, можно использовать обычные потоки, можно даже сделать экземпляры Thread бинами и можно использовать спринговый TaskExecutor.

[nuclear_kote]

Сергей Горностаев, спасибо)