проблема при реализации многопоточности с контекстом javaStreamingContext в Java

Question

Я сталкиваюсь с проблемой, когда пытаюсь остановить JavaStreamingContext объект, который находится в отдельном потоке. Я создаю новый поток каждые 5 секунд с taskExecutor, а JavaStreamingContext является частью переменной localthread каждого потока.

Всякий раз, когда я отправляю запрос на отдых из пользовательского интерфейса, я хочу остановить javaStreamingContext объект этого конкретного потока. У меня есть имя потока для каждого потока, который имеет javaStreamingContext объект, в методе остальных значение объекта отображается как null.

Итак, если я не могу получить доступ к переменной threadlocal из внешнего потока, то как остановить объект javaStreamingContext?

Какой подход я должен использовать? Предложите мне хороший подход.

Answer 1

Вы можете написать метод stopStreamingContext () внутри класса, потоки которого создаются каждые 5 секунд. Внутри этого метода вы можете остановить потоковый контекст. Поэтому, когда вы получите запрос на отдых, просто вызовите stopStreamingContext () с потоком.