ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

ExecutorService executorService = Executors.newSingleThreadExecutor();

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

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

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

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

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

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

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