Запуск бесконечного цикла при работе с вебсокетами

@florgas · Регистрация: 28.09.2010

Author24 — интернет-сервис помощи студентам

Приложение работает с вебсокетами.
Приходит сообщение, после которого на сервере надо запустить бесконечный цикл.
Написал этот цикл в новом потоке.
Все работает, можно работать с другими сервисами, или принимать ajax'ы. Но цикл блокирует @OnMessage вебсокетов, из которого запускался новый поток.
Подскажите как запустить этот цикл так, чтобы можно было продолжить работу с вебсокетами параллельно с выполнением цикла.

Java

@OnMessage
    public void onMessage(Session session, Message message) throws IOException, InterruptedException, EncodeException {
        if (Objects.equals(message.getSubject(), "start-game")) {
            GameInfinityLoop gameInfinityLoop = new GameInfinityLoop();
            gameInfinityLoop.run();
}

Java

public class GameInfinityLoop implements Runnable {
 
    private WebApplicationContext context = ContextLoader.getCurrentWebApplicationContext();
    private GameService gameService = context.getBean(GameService.class);
 
    @Override
    public void run() {
        try {
            gameService.game();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (EncodeException e) {
            e.printStackTrace();
        }
    }
}

Добавлено через 1 час 39 минут
Проблема решена.
Решение:

Java

@OnMessage
    public void onMessage(Session session, Message message) throws IOException, InterruptedException, EncodeException {
        if (Objects.equals(message.getSubject(), "start-game")) {
            new GameInfinityLoop().start();

Java

public class GameInfinityLoop extends Thread {
 
    private WebApplicationContext context = ContextLoader.getCurrentWebApplicationContext();
    private GameService gameService = context.getBean(GameService.class);
 
    @Override
    public void run() {
        try {
            gameService.game();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (EncodeException e) {
            e.printStackTrace();
        }
    }
}

@KEKCoGEN · 15.07.2018, 00:52

Сообщение от florgas

Но цикл блокирует @OnMessage вебсокетов, из которого запускался новый поток.

новый поток не запускается методом run()

@KEKCoGEN 2399 / 2224 / 565 Регистрация: 28.12.2010 Сообщений: 8,672
	15.07.2018, 00:52	2
	Сообщение от florgas Но цикл блокирует @OnMessage вебсокетов, из которого запускался новый поток. новый поток не запускается методом run() 0