阻止Java应用程序退出，直到ThreadPool为空

Question

我有一个ExecutorService坐在一个singleton类中，它接收来自许多不同类的任务。在应用程序关闭时，我需要等待池被清空，然后才允许应用程序退出。

private static NotificationService instance = null; 

private ExecutorService executorService = Executors.newFixedThreadPool(25); 

public static synchronized NotificationService getInstance() { 
    if (instance == null) { 
     instance = new NotificationService(true); 
    } 
    return instance; 
} 

在使用本NotificationService，它经常发生，我重新启动应用程序和executorService还没有处理完所有的通知。

对于测试，我可以手动关闭executorService并等待所有任务完成。

public static boolean canExit() throws InterruptedException { 
    NotificationService service = getInstance(); 
    service.executorService.shutdown(); 
    service.executorService.awaitTermination(30, TimeUnit.SECONDS); 
    return service.executorService.isTerminated(); 
} 

覆盖finalize方法并等待直到池为空是否可靠和安全？从我读过的内容来看，并不总是调用finalize，尤其是在使用单例类时。

@Override 
protected void finalize() throws Throwable { 
    while (!canExit()){ 
     Thread.sleep(100); 
    } 
    super.finalize(); 
} 

此代码包含在将包含在另一个应用程序库，所以没有主要的方法，我可以等到池是空的，除非我用它这样做是不强迫人大。

什么是正确的方式来拖延应用程序（一段合理的时间）从终止，直到池是空的？

Answer 1

您可以使用addShutdownHook来捕获进程终止事件并在那里等待池。

例如：

Runtime.getRuntime().addShutdownHook(new Thread() { 
     public void run() { 
     NotificationService service = getInstance(); 
     service.executorService.shutdown(); 
     service.executorService.awaitTermination(30, TimeUnit.SECONDS); 
     } 
    }); 

Answer 2

这里回答：Java Finalize method call when close the application 终结默认情况下不和做这个功能在退出运行已被弃用。

一个共同的建议是使用Runtime.addShutdownHook但要注意以下在线文档的：

关闭挂钩还应该迅速完成其工作。当一个程序调用退出时，期望虚拟机会立即关闭并退出。当由于用户注销或系统关闭而导致虚拟机终止时，底层操作系统可能只允许关闭并退出的固定时间。因此，尝试任何用户交互或在关闭钩子中执行长时间运行计算是不可取的。

诚实地说，确保所有事情得到适当清理的最好方法是拥有自己的应用程序生命周期，您甚至可以在要求VM退出之前结束自己的应用程序生命周期。

Answer 3

不要在库中使用阻塞关闭钩子或任何类似的东西。你永远不知道图书馆是如何被使用的。所以它应该总是取决于使用你的库的代码在关闭时采取明智的行动。

当然，你必须提供必要的API，例如，加入生命周期的方法到类：

public class NotificationService { 
    ... 

    public void start() { 
     ... 
    } 

    /** 
    * Stops this notification service and waits until 
    * all notifications have been processed, or a timeout occurs. 
    * @return the list of unprocessed notification (in case of a timeout), 
       or an empty list. 
    */ 
    public List<Notification> stop(long timeout, TimeUnit unit) { 
     service.shutdown(); 
     if (!service.awaitTermination(timeout, unit)) { 
      List<Runnable> tasks = service.shutdownNow(); 
      return extractNotification(tasks); 
     } 
     return Collections.emptyList(); 
    } 

    private List<Notification> extractNotification(List<Runnable> tasks) { 
     ... 
    } 
} 

然后，应用程序代码可以采取必要的行动来处理你的服务，例如：

public static void main(String[] args) { 
    NotificationService service = new NotificationService(...); 
    service.start(); 
    try { 
     // use service here 
    } finally { 
     List<Notification> pending = service.stop(30, TimeUnit.SECONDS); 
     if (!pending.isEmpty()) { 
      // timeout occured => handle pending notifications 
     } 
    } 
} 

顺便说一句：避免使用单身人士，如果可行的话。