我的程序不会以Executor返回/结束

Question

给定以下使用多线程的Java示例：

 import java.util.concurrent.*;

 public class SquareCalculator {
     private ExecutorService executor = Executors.newSingleThreadExecutor();

     public Future<Integer> calculate(Integer input) {
         return executor.submit( () -> {
             Thread.sleep(1000);
             return input * input;
         });
     }

     public static void main(String[] args) {
         try {
             Future<Integer> future = new SquareCalculator().calculate(10);
             while (!future.isDone()){
                 System.out.println("Calculating...");
                 Thread.sleep(300);
             }

             Integer result = future.get();
             System.out.println("we got: " + result);
         } catch(InterruptedException | ExecutionException e) {
             System.out.println("had exception");
         }
     }
 }

它产生：

java SquareCalculator
Calculating...
Calculating...
Calculating...
Calculating...
we got: 100

但应用程序永远不会终止。

我是不是该加入这条线什么的？

Answer 1

您需要在程序快结束时关闭executor framework，并等待它正常终止。。

executor.shutdown();
try {
    executor.awaitTermination(4 * 3600, TimeUnit.SECONDS);
} catch (Exception e) {
    e.printStackTrace();
}

Answer 2

我打赌你想添加这样的内容：

   finally {
        if (executor != null) {
            executor.shutdown();
        }
    }

Answer 3

应该发表评论，但声誉不够。

您应该调用executor上的shutdown。您可以从以下链接获得更多详细信息：在ExecutorService上调用shutdown（）的原因