将ExecutorService转换为Java中的守护程序

小编典典

将ExecutorService转换为Java中的守护程序

java

我正在Java 1.6中使用ExecutoreService，其启动方式仅由

ExecutorService pool = Executors.newFixedThreadPool(THREADS).

当我的主线程完成时（以及线程池处理的所有任务），该池将阻止我的程序关闭，直到我显式调用

pool.shutdown();

我是否可以通过以某种方式将此池使用的内部线程管理转换为守护线程来避免调用此方法？还是我在这里想念什么。

阅读 432

2020-09-08

共1个答案

小编典典

Marco13的答案可能是最简单，首选的解决方案，因此不要被投票分歧（我的答案比以前大几岁）或验收标记所欺骗（这意味着我的解决方案适用于OP环境，而不是最好的）。

您可以ThreadFactory用来将Executor中的线程设置为守护程序。这将以某种方式影响执行程序服务，该服务也将成为守护程序线程，因此，如果没有其他非守护程序线程，它将（以及它所处理的线程）停止。这是简单的示例：

ExecutorService exec = Executors.newFixedThreadPool(4,
        new ThreadFactory() {
            public Thread newThread(Runnable r) {
                Thread t = Executors.defaultThreadFactory().newThread(r);
                t.setDaemon(true);
                return t;
            }
        });

exec.execute(YourTaskNowWillBeDaemon);

但是，如果您想让执行程序完成任务的执行程序，并同时shutdown()在应用程序完成时自动调用其方法，则可能需要用Guava
包装您的执行程序MoreExecutors.getExitingExecutorService。

ExecutorService exec = MoreExecutors.getExitingExecutorService(
        (ThreadPoolExecutor) Executors.newFixedThreadPool(4), 
        100_000, TimeUnit.DAYS//period after which executor will be automatically closed
                             //I assume that 100_000 days is enough to simulate infinity
);
//exec.execute(YourTask);
exec.execute(() -> {
    for (int i = 0; i < 3; i++) {
        System.out.println("daemon");
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
});

2020-09-08