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

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

1public class MyThreadPoolDemo {
2    public static void main(String[] args) {
3        ExecutorService threadPool = new ThreadPoolExecutor(2,
4                5,
5                1L,
6                TimeUnit.SECONDS,
7                new LinkedBlockingQueue<Runnable>(3),
8                Executors.defaultThreadFactory(),
9                new ThreadPoolExecutor.AbortPolicy());
10
11        try {
12//        模拟10个用户来办理业务，每个用户就是一个来自外部的请求线程。
13            for (int i = 1; i <= 5; i++) {
14                threadPool.execute(() -> {
15                    System.out.println(Thread.currentThread().getName() + "\t 办理业务");
16                });
17            }
18        } catch (Exception e) {
19            e.printStackTrace();
20        } finally {
21            threadPool.shutdown();
22        }
23    }
24}

当线程为5时执行结果：

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

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

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

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