java - 在java中使用javaStreamingContext上下文实现多线程时出现问题

Question

当我尝试停止位于单独线程中的 JavaStreamingContext 对象时，我遇到了问题。我使用 taskExecutor 每 5 秒创建一个新线程，并且 JavaStreamingContext 是每个线程的 localthread 变量的一部分。

每当我从 UI 发布休息请求时，我都想停止该特定线程的 javaStreamingContext 对象。我有每个具有 javaStreamingContext 对象的线程的线程名称，在休息方法中对象值显示为 null 。

那么如果我无法从外部线程访问threadlocal变量，那么如何停止javaStreamingContext对象？

我应该使用哪种方法？建议我一个好的方法。

Answer 1

您可以在类中编写一个方法 stopStreamingContext()，该方法每 5 秒创建一次线程。在此方法中，您可以停止流上下文。因此，每当您收到休息请求时，只需使用线程调用 stopStreamingContext() 即可。