执行器服务在可完成的将来使用时未正确关闭

Question

我异步执行三个任务

  CompletableFuture<IStoryDetail> iStoryDetailCompletableFuture = CompletableFuture.supplyAsync(()->storyRepository.getStoryDetails(id));
 CompletableFuture<List<Comment>> iCommentFuture = CompletableFuture.supplyAsync(() -> commentRepository.getComments(id));
 CompletableFuture<List<Images>> iImageFuture = CompletableFuture.supplyAsync(() -> imageRepository.getImagesByStoryId(id)); 

在那之后，我加入了所有这些任务

CompletableFuture.allOf(iCommentFuture, iStoryDetailCompletableFuture, iImageFuture)
          ;

这似乎很好，但当我决定在Executor服务中运行Completable future时

  @Autowired
  ICommentRepository commentRepository;

  ExecutorService executorService = Executors.newFixedThreadPool(4);




CompletableFuture<IStoryDetail> iStoryDetailCompletableFuture = CompletableFuture.supplyAsync(()->storyRepository.getStoryDetails(id),executorService);
     CompletableFuture<List<Comment>> iCommentFuture = CompletableFuture.supplyAsync(() -> commentRepository.getComments(id),executorService);
     CompletableFuture<List<Images>> iImageFuture = CompletableFuture.supplyAsync(() -> imageRepository.getImagesByStoryId(id),executorService);



iStoryDetailCompletableFuture.thenApply(story -> objectMap.putIfAbsent(story.getClass().getName(),story));
  iCommentFuture.thenApply(comments -> objectMap.putIfAbsent(Comment.class.getName(),comments));
  iImageFuture.thenApply(images -> objectMap.putIfAbsent(Images.class.getName(),images));

   CompletableFuture.allOf(iCommentFuture, iStoryDetailCompletableFuture, iImageFuture).thenRun(() -> executorService.shutdown())
      ;

执行器服务似乎无法正确关闭，对控制器的进一步请求被阻止，我在这里错过了什么，感谢您的帮助

删除thenRun（（）后-

Answer 1

shutdown（）等待任何现有托管线程完成。如果您不关心它管理的线程是否已完成，请使用shutdownNow（）。