問題描述

我正在Java 1.6中使用一個ExecutoreService，簡單地開始

ExecutorService pool = Executors.newFixedThreadPool(THREADS). 

當我的主執行緒完成(以及由執行緒池處理的所有任務)時，此池將阻止我的程式關閉，直到我明確地呼叫

pool.shutdown();

我可以避免通過某種方式將這個池使用的內部執行緒管理轉換成deamon執行緒來呼叫嗎？或者我在這裡遺漏了一些東西。

最佳解決方案

大概最簡單和最優的解決方案是在Marco13’s answer中，所以不要被投票差異(我的回答是幾年前)或接受標記(這意味著我的解決方案適合於OP情況不是最好的)。

您可以使用ThreadFactory將Executor中的執行緒設定為守護程式。這將影響執行器服務，它也將成為守護程序執行緒，因此如果沒有其他non-daemon執行緒，它(以及由其處理的執行緒)將停止。這是一個簡單的例子：

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’s 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();
        }
    }
});

次佳解決方案

已經有一個內建功能用於建立一個ExecutorService，在一段時間不活動後終止所有執行緒：您可以建立一個ThreadPoolExecutor，傳遞所需的時序資訊，然後在此執行器服務上呼叫allowCoreThreadTimeout(true)：

/**
 * Creates an executor service with a fixed pool size, that will time 
 * out after a certain period of inactivity.
 * 
 * @param poolSize The core- and maximum pool size
 * @param keepAliveTime The keep alive time
 * @param timeUnit The time unit
 * @return The executor service
 */
public static ExecutorService createFixedTimeoutExecutorService(
    int poolSize, long keepAliveTime, TimeUnit timeUnit)
{
    ThreadPoolExecutor e = 
        new ThreadPoolExecutor(poolSize, poolSize,
            keepAliveTime, timeUnit, new LinkedBlockingQueue<Runnable>());
    e.allowCoreThreadTimeOut(true);
    return e;
}

EDIT Referring to the remarks in the comments: Note that this thread pool executor will not automatically shut down when the application exits. The executor will continue to run after the application exits, but no longer than the keepAliveTime. If, depending on the precise application requirements, the keepAliveTime has to be longer than a few seconds, the solution in the answer by Pshemo may be more appropriate: When the threads are set to be daemon threads, then they will end immediately when the application exits.

第三種解決方案

我會使用Guava的ThreadFactoryBuilder類。

ExecutorService threadPool = Executors.newFixedThreadPool(THREADS, new ThreadFactoryBuilder().setDaemon(true).build());

如果你還沒有使用Guava，我會去一個ThreadFactory子類，如Pshemo’s answer頂部所述

第四種方案

是。

您只需建立自己的ThreadFactory類，即建立守護程序執行緒而不是常規執行緒。

參考文獻

注：本文內容整合自google/baidu/bing輔助翻譯的英文資料結果。如果您對結果不滿意，可以加入我們改善翻譯效果:gxnotes#qq.com(#替換為@)。