线程池，及7大参数，4大拒绝策略

本文介绍: 在这个例子中，我们创建了一个线程池，并提交了10个任务给线程池执行。线程空闲时间是非核心线程在空闲状态下被保留的时间，超过这个时间就会被销毁，直到线程数达到核心线程数为止。核心线程数是线程池中一直存活的线程数量，即使它们处于空闲状态也不会被销毁。拒绝策略定义了当任务无法被接受时的处理方式，例如抛出异常、丢弃任务等。线程工厂用于创建新的线程，可以自定义线程的名称、优先级等属性。最大线程数是线程池中允许的最大线程数量，包括活动和空闲线程。时间单位用于指定线程空闲时间的单位，可以是秒、毫秒等。

线程池由以下几个主要组件构成：

核心线程数是线程池中一直存活的线程数量，即使它们处于空闲状态也不会被销毁。

最大线程数是线程池中允许的最大线程数量，包括活动和空闲线程。

线程空闲时间是非核心线程在空闲状态下被保留的时间，超过这个时间就会被销毁，直到线程数达到核心线程数为止。

时间单位用于指定线程空闲时间的单位，可以是秒、毫秒等。

任务队列用于存储等待执行的任务，可以是有界队列或无界队列。

抛出RejectedExecutionException异常，默认策略。

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, 
    maximumPoolSize, 
    keepAliveTime, 
    timeUnit, 
    blockingQueue, 
    threadFactory, 
    new ThreadPoolExecutor.AbortPolicy()
);

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, 
    maximumPoolSize, 
    keepAliveTime, 
    timeUnit, 
    blockingQueue, 
    threadFactory, 
    new ThreadPoolExecutor.CallerRunsPolicy()
);

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, 
    maximumPoolSize, 
    keepAliveTime, 
    timeUnit, 
    blockingQueue, 
    threadFactory, 
    new ThreadPoolExecutor.DiscardOldestPolicy()
);

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize, 
    maximumPoolSize, 
    keepAliveTime, 
    timeUnit, 
    blockingQueue, 
    threadFactory, 
    new ThreadPoolExecutor.DiscardPolicy()
);

import java.util.concurrent.*;

public class ThreadPoolExample {

    public static void main(String[] args) {
        int corePoolSize = 2;
        int maximumPoolSize = 5;
        long keepAliveTime = 1;
        TimeUnit timeUnit = TimeUnit.SECONDS;
        BlockingQueue<Runnable&gt; blockingQueue = new LinkedBlockingQueue<>();
        ThreadFactory threadFactory = Executors.defaultThreadFactory();
        RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.AbortPolicy();

        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                timeUnit,
                blockingQueue,
                threadFactory,
                rejectedExecutionHandler
        );

        // 提交任务给线程池
        for (int i = 0; i < 10; i++) {
            final int taskIndex = i;
            executor.execute(() -> {
                System.out.println("Thread: " + Thread.currentThread().getName() + ", executing task " + taskIndex);
                try {
                    Thread.sleep(2000); // 模拟任务执行时间
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}