线程池拒绝策略加入到阻塞队列

你可以通过将自定义的拒绝策略添加到线程池的阻塞队列中来实现。在Java中，线程池的阻塞队列通常使用`BlockingQueue`接口的实现类。下面是一种常见的做法：

1. 创建一个实现了`RejectedExecutionHandler`接口的自定义拒绝策略类，例如`CustomRejectedExecutionHandler`。
2. 在自定义拒绝策略类中，重写`rejectedExecution`方法，该方法会在任务被线程池拒绝执行时被调用。在该方法中，你可以根据需求对被拒绝的任务进行处理，例如将其添加到阻塞队列中。
3. 创建一个线程池，使用`ThreadPoolExecutor`类。在创建线程池时，可以指定阻塞队列的实现类，并将自定义的拒绝策略对象作为参数传递给线程池构造函数。

以下是一个示例代码：

import java.util.concurrent.*;

public class CustomRejectedExecutionHandler implements RejectedExecutionHandler {
    private final BlockingQueue<Runnable> queue;

    public CustomRejectedExecutionHandler(BlockingQueue<Runnable> queue) {
        this.queue = queue;
    }

    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        try {
            queue.put(r); // 将被拒绝的任务添加到阻塞队列中
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class Main {
    public static void main(String[] args) {
        int corePoolSize = 5;
        int maximumPoolSize = 10;
        long keepAliveTime = 5000;
        BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(100);
        RejectedExecutionHandler rejectionHandler = new CustomRejectedExecutionHandler(queue);

        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                TimeUnit.MILLISECONDS,
                queue,
                rejectionHandler
        );

        // 使用线程池执行任务
        threadPool.execute(() -> {
            // 任务逻辑
        });
    }
}

在上面的示例中，自定义拒绝策略类`CustomRejectedExecutionHandler`将被拒绝的任务添加到阻塞队列中。然后，创建一个`ThreadPoolExecutor`线程池，并将阻塞队列和自定义的拒绝策略对象传递给构造函数。

这样，当线程池无法接受新任务时，会调用自定义的拒绝策略，并将被拒绝的任务添加到阻塞队列中。这个阻塞队列将会在有空闲线程时被持续消费执行。