ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

ExecutorService executorService = Executors.newSingleThreadExecutor();

/**
 * schedule()：調(diào)度一個(gè)任務(wù)在指定的延遲后執(zhí)行一次。
 * scheduleAtFixedRate()：調(diào)度任務(wù)以固定的頻率周期性執(zhí)行，任務(wù)之間的間隔時(shí)間是固定的。
 * scheduleWithFixedDelay()：調(diào)度任務(wù)以固定的延遲時(shí)間周期性執(zhí)行，任務(wù)之間的延遲是固定的。
 */
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

// 調(diào)度一個(gè)任務(wù)，延遲 3 秒后執(zhí)行
scheduledThreadPool.schedule(() -> {
System.out.println("任務(wù)在延遲 3 秒后執(zhí)行，當(dāng)前線程: " + Thread.currentThread().getName());
}, 3, TimeUnit.SECONDS);

scheduledThreadPool.scheduleAtFixedRate(() -> {
System.out.println("任務(wù)在固定間隔 2 秒執(zhí)行，當(dāng)前線程: " + Thread.currentThread().getName());
}, 0, 2, TimeUnit.SECONDS); // 第一個(gè)參數(shù) 0 是初始延遲，第二個(gè)參數(shù) 2 是間隔時(shí)間

// 每 2 秒執(zhí)行一次任務(wù)，任務(wù)執(zhí)行完后等待 2 秒再執(zhí)行下一個(gè)
scheduledThreadPool.scheduleWithFixedDelay(() -> {
System.out.println("任務(wù)在固定延遲 2 秒執(zhí)行，當(dāng)前線程: " + Thread.currentThread().getName());
}, 0, 2, TimeUnit.SECONDS); // 第一個(gè)參數(shù) 0 是初始延遲，第二個(gè)參數(shù) 2 是延遲時(shí)間

/**
 常見(jiàn)的拒絕策略：
 AbortPolicy（默認(rèn)）：直接拋出 RejectedExecutionException 異常。
 CallerRunsPolicy：由調(diào)用者線程處理任務(wù)。
 DiscardPolicy：丟棄任務(wù)。
 DiscardOldestPolicy：丟棄隊(duì)列中最舊的任務(wù)，并嘗試提交當(dāng)前任務(wù)。`
 **/
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, // 核心線程數(shù)
    maximumPoolSize, // 最大線程數(shù)
    keepAliveTime, // 空閑線程存活時(shí)間
    unit, // 存活時(shí)間單位
    workQueue, // 任務(wù)隊(duì)列
    threadFactory, // 線程工廠
    handler // 拒絕策略
);

//示例
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5,  // 核心線程數(shù)
        10, // 最大線程數(shù)
        60L, // 空閑線程最大存活時(shí)間（單位：秒）
        TimeUnit.SECONDS, // 時(shí)間單位
        new LinkedBlockingQueue<Runnable>(100), // 阻塞隊(duì)列
        Executors.defaultThreadFactory(), // 默認(rèn)線程工廠
        new ThreadPoolExecutor.CallerRunsPolicy()// 拒絕策略
);

// 如果你需要處理大量的計(jì)算密集型任務(wù)，并且任務(wù)可以分割成更小的子任務(wù)，可以使用 ForkJoinPool。它是一種用于并行計(jì)算的線程池。
ForkJoinPool forkJoinPool = new ForkJoinPool(3);