Java创建线程池的方式实现

ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

ExecutorService executorService = Executors.newSingleThreadExecutor();

/**
 * schedule()：调度一个任务在指定的延迟后执行一次。
 * scheduleAtFixedRate()：调度任务以固定的频率周期性执行，任务之间的间隔时间是固定的。
 * scheduleWithFixedDelay()：调度任务以固定的延迟时间周期性执行，任务之间的延迟是固定的。
 */
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

// 调度一个任务，延迟 3 秒后执行
scheduledThreadPool.schedule(() -> {
System.out.println("任务在延迟 3 秒后执行，当前线程: " + Thread.currentThread().getName());
}, 3, TimeUnit.SECONDS);

scheduledThreadPool.scheduleAtFixedRate(() -> {
System.out.println("任务在固定间隔 2 秒执行，当前线程: " + Thread.currentThread().getName());
}, 0, 2, TimeUnit.SECONDS); // 第一个参数 0 是初始延迟，第二个参数 2 是间隔时间

// 每 2 秒执行一次任务，任务执行完后等待 2 秒再执行下一个
scheduledThreadPool.scheduleWithFixedDelay(() -> {
System.out.println("任务在固定延迟 2 秒执行，当前线程: " + Thread.currentThread().getName());
}, 0, 2, TimeUnit.SECONDS); // 第一个参数 0 是初始延迟，第二个参数 2 是延迟时间

/**
 常见的拒绝策略：
 AbortPolicy（默认）：直接抛出 RejectedExecutionException 异常。
 CallerRunsPolicy：由调用者线程处理任务。
 DiscardPolicy：丢弃任务。
 DiscardOldestPolicy：丢弃队列中最旧的任务，并尝试提交当前任务。`
 **/
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, // 核心线程数
    maximumPoolSize, // 最大线程数
    keepAliveTime, // 空闲线程存活时间
    unit, // 存活时间单位
    workQueue, // 任务队列
    threadFactory, // 线程工厂
    handler // 拒绝策略
);

//示例
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5,  // 核心线程数
        10, // 最大线程数
        60L, // 空闲线程最大存活时间（单位：秒）
        TimeUnit.SECONDS, // 时间单位
        new LinkedBlockingQueue<Runnable>(100), // 阻塞队列
        Executors.defaultThreadFactory(), // 默认线程工厂
        new ThreadPoolExecutor.CallerRunsPolicy()// 拒绝策略
);

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