清理使用 ExecutorService 提交的线程

Question

我的代码如下：

public Future<String> getFuture() {
  ExecutorService executorService = Executors.newSingleThreadExecutor();
  Future<String> future = executorService.submit(() -> {
    //do something
    return "test string";
  });
  executorService.shutDown(); // is this correct?
  return future;
}

我正在从其他类调用此服务以获得未来：

 Future<String> future = getFuture();
 String result = future.get();
 future.cancel(true); // will this assure that there wont be any thread leak?

现在executorService.shutDown() 和future.cancel(true) 将确保不会有线程泄漏？

请注意，在调用future.cancel(true) 后，当我在Thread.getAllStackTraces() 的结果中检查当前正在运行的线程时，我仍然可以找到未来执行的线程。

Answer 1

你问错问题了！

在一个方法中创建一个服务然后把它扔掉是没有意义的。

创建该服务实例并不是免费的。这种抽象的整个想法是确保高效使用基础设施元素！

换句话说：退后一步，重新设计你的设计；这样这个服务就变成了某个类的field！是的，这可能会变得很复杂。但最有可能的是，与继续您的问题中显示的方法相比，花时间在那个角落会获得更多的长期回报。

Answer 2

• 创建执行程序然后在每个方法调用中将其丢弃是一个坏主意。

现在没有 executorService.shutDown() 和 future.cancel(true) 来保证不会有线程泄漏？

没有。
executorService.shutdown() 只会继续运行当前任务并拒绝新提交的任务。

future.cancel(true) 将中断当前正在运行的相应任务（但您有责任检查任务是否被中断并尽快完成任务的执行）

请注意，在调用 future.cancel(true) 后，当我在 Thread.getAllStackTraces() 的结果中检查当前正在运行的线程时，我仍然可以找到执行 future 的线程。

正如我之前提到的，future.cancel(true) 不会停止线程。它只会发送中断。