Java多线程之线程池的手写改造和拒绝策略 4年前

目录
自定义线程池的使用
四种拒绝策略代码体现
1. 自定义线程池的使用
自定义线程池（拒绝策略默认AbortPolicy）

copy
public class MyThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService threadPool = new ThreadPoolExecutor(2,
                5,
                1L,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<Runnable>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy());

        try {
//        模拟10个用户来办理业务，每个用户就是一个来自外部的请求线程。
            for (int i = 1; i <= 5; i++) {
                threadPool.execute(() -> {
                    System.out.println(Thread.currentThread().getName() + "\t 办理业务");
                });
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            threadPool.shutdown();
        }
    }
}

当线程为5时执行结果：

2. 四种拒绝策略代码体现
AbortPolicy(默认）：直接抛出RejectedExecutionException异常阻止系统正常运行。
当线程数为9时，抛出异常。

CallerRunsPolicy："调用者运行"一种调节机制，该策略既不会抛弃任务，也不会抛出异常，而是将某些任务回退到调用者，从而降低新任务的流量。
CallerRunsPolicy 拒绝策略，将线程变为10时执行结果

DiscardOldestPolicy：抛弃队列中等待最久的任务，然后把当前任务加入队列中尝试再次提交当前任务。
DiscardOldestPolicy拒绝策略，将线程变为10时执行结果：

DiscardPolicy：直接丢弃任务，不予任何处理也不抛出异常。如果允许任务丢失，这是最好的一种方案。
DiscardPolicy拒绝策略，直接丢包，将线程变为10时执行结果：