正常关闭线程和执行程序

Question

下面的代码尝试做到这一点。

该代码将永远循环并检查是否有任何待处理的请求要处理。如果存在，它将创建一个新线程来处理请求并将其提交给执行者。一旦所有线程完成，它将休眠60秒，然后再次检查未决请求。

public static void main(String a[]){
    //variables init code omitted
    ExecutorService service = Executors.newFixedThreadPool(15);
    ExecutorCompletionService<Long> comp = new ExecutorCompletionService<Long>(service);
    while(true){
        List<AppRequest> pending = service.findPendingRequests();
        int noPending = pending.size();
        if (noPending > 0) {
            for (AppRequest req : pending) {
                Callable<Long> worker = new RequestThread(something, req);
                comp.submit(worker);
            }
        }
        for (int i = 0; i < noPending; i++) {
            try {
                Future<Long> f = comp.take();
                long name;
                try {
                    name = f.get();
                    LOGGER.debug(name + " got completed");
                } catch (ExecutionException e) {
                    LOGGER.error(e.toString());
                }
            } catch (InterruptedException e) {
                LOGGER.error(e.toString());
            }
        }
        TimeUnit.SECONDS.sleep(60);
    }

  }

我的问题是这些线程完成的大多数处理都是针对数据库的。该程序将在Windows计算机上运行。当有人尝试关闭或注销计算机时，这些线程会发生什么？如何正常关闭正在运行的线程以及执行程序？

Answer 1

典型的有序关闭ExecutorService可能看起来像这样：

final ExecutorService executor;

Runtime.getRuntime().addShutdownHook(new Thread() {
    public void run() {
        executor.shutdown();
        if (!executor.awaitTermination(SHUTDOWN_TIME)) { //optional *
            Logger.log("Executor did not terminate in the specified time."); //optional *
            List<Runnable> droppedTasks = executor.shutdownNow(); //optional **
            Logger.log("Executor was abruptly shut down. " + droppedTasks.size() + " tasks will not be executed."); //optional **
        }
    }
});

您可以记录，在等待您愿意等待的时间之后，执行者仍有任务要处理。

*您可以尝试强制执行者的工作线程放弃其当前任务，并确保它们不会启动任何剩余的任务。

请注意，当用户向您的java进程发出中断或ExecutorService仅包含守护程序线程时，上述解决方案将起作用。相反，如果ExecutorService包含尚未完成的非守护线程，则JVM将不会尝试关闭，因此不会调用关闭挂钩。

如果尝试作为离散应用程序生命周期（而不是服务）的一部分关闭进程，则不应将关闭代码放在关闭挂钩中，而应放在程序终止的适当位置。