线程池的4种拒绝策略
作者：互联网
一、总览4种拒绝策略
AbortPolicy abortPolicy = new ThreadPoolExecutor.AbortPolicy();
DiscardPolicy discardPolicy = new ThreadPoolExecutor.DiscardPolicy();
DiscardOldestPolicy discardOldestPolicy = new ThreadPoolExecutor.DiscardOldestPolicy();
CallerRunsPolicy callerRunsPolicy = new ThreadPoolExecutor.CallerRunsPolicy();
如果去看ThreadPoolExecutor的源码，会看到四种拒绝策略 其实在ThreadPoolExecutor是四个内部类
二、逐一介绍
1、AbortPolicy
当任务添加到线程池中被拒绝时，它将抛出 RejectedExecutionException 异常。（该策略下，直接丢弃任务，并抛出RejectedExecutionException异常）
只有第一个会抛异常，这个还是默认的拒绝策略，其它3个都是默默的消化掉问题。
当任务添加到线程池中之所以被拒绝，可能是由于：第一，线程池异常关闭。第二，任务数量超过线程池的最大限制。
2、DiscardPolicy
当任务添加到线程池中被拒绝时，默认情况下它将丢弃被拒绝的任务。（即该策略下，直接丢弃任务，什么都不做）
3、DiscardOldestPolicy
当任务添加到线程池中被拒绝时，线程池会放弃等待队列中最旧的未处理任务，然后将被拒绝的任务添加到等待队列中。
（该策略下，抛弃进入队列最早的那个任务，然后尝试把这次拒绝的任务放入队列）
4、CallerRunsPolicy
不进入线程池执行，在这种方式（CallerRunsPolicy）中，任务将由调用者线程去执行。
（用于被拒绝任务的处理程序，它直接在 execute 方法的调用线程中运行被拒绝的任务；如果执行程序已关闭，则会丢弃该任务。）
测试，使用的runnable代码
package com.yk.thread.threadpool.executors.reject;
/**
* @author yangkai 2020/3/27
*/
public class MyRunnable implements Runnable {
private String name;
public MyRunnable(String name) {
this.name = name;
}
@Override
public void run() {
try {
String name = "当前线程名称：" + Thread.currentThread().getName();
System.out.println(name + ", " + this.name + " is running.");
Thread.sleep(200);
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* AbortPolicy 当任务添加到线程池中被拒绝时，它将抛出 RejectedExecutionException 异常。
* <p>
* 结果说明：
* 将"线程池的拒绝策略"由DiscardPolicy修改为AbortPolicy之后，当有任务添加到线程池被拒绝时，会抛出RejectedExecutionException。
*
* @author yk on 2020/3/27
*/
public class TestAbortPolicy {
private static final int THREADS_SIZE = 1;
private static final int TASK_MAX = 10;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("Test-Rejected-Policy-Pool-%d").build();
// 创建线程池。线程池的"最大池大小"和"核心池大小"都为1(THREADS_SIZE)，"线程池"的阻塞队列容量为1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
// 新建10个任务，并将它们添加到线程池中。
for (int i = 0; i < TASK_MAX; i++) {
Runnable myRunnable = new MyRunnable("task [ " + i + " ]");
try {
pool.execute(myRunnable);
} catch (RejectedExecutionException e) {
System.out.println(e.toString());
}
}
// 关闭线程池
pool.shutdown();
}
}
运行结果：
只有0，1两个任务运行OK，其它的8个任务，在往线程池丢的时候，被线程池拒绝了，而且还抛了异常，被catch住了，catch了8次。
/**
* CallerRunsPolicy 当任务添加到线程池中被拒绝时，会在线程池当前正在运行的Thread线程池中处理被拒绝的任务
* 翻译一下：就是不进入线程池执行，在这种方式（CallerRunsPolicy）中，任务将有调用者线程去执行
*
* @author yk on 2020/3/27
*/
public class TestCallerRunsPolicy {
private static final int THREADS_SIZE = 1;
private static final int TASK_MAX = 10;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("Test-Rejected-Policy-Pool-%d").build();
// 创建线程池。线程池的"最大池大小"和"核心池大小"都为1(THREADS_SIZE)，"线程池"的阻塞队列容量为1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY), namedThreadFactory);
// 设置线程池的拒绝策略为"CallerRunsPolicy"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 新建10个任务，并将它们添加到线程池中。
for (int i = 0; i < TASK_MAX; i++) {
Runnable myRunnable = new MyRunnable("task [ " + i + " ]");
try {
pool.execute(myRunnable);
} catch (Exception e) {
System.out.println(e.toString());
}
}
// 关闭线程池
pool.shutdown();
}
}
运行结果图：
在任务往线程池丢的时候，发现线程池已经装不下了，那么这个时候，就让往线程池丢任务丢这个线程来执行这个任务，在此例子就是main线程了，从结果图可见线程池里面的一个线程和main一起干活，把10个任务给搞完了。
/**
* 当任务添加到线程池中被拒绝时，线程池会放弃等待队列中最旧的未处理任务，然后将被拒绝的任务添加到等待队列中。
* <p>
* 结果说明：
* 将"线程池的拒绝策略"由DiscardPolicy修改为DiscardOldestPolicy之后，当有任务添加到线程池被拒绝时，
* 线程池会丢弃阻塞队列中末尾的任务，然后将被拒绝的任务添加到末尾。
*
* @author yk on 2020/3/27
*/
public class TestDiscardOldestPolicy {
private static final int THREADS_SIZE = 1;
private static final int TASK_MAX = 10;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("Test-Rejected-Policy-Pool-%d").build();
// 创建线程池。线程池的"最大池大小"和"核心池大小"都为1(THREADS_SIZE)，"线程池"的阻塞队列容量为1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY), namedThreadFactory);
// 设置线程池的拒绝策略为"DiscardOldestPolicy"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
// 新建10个任务，并将它们添加到线程池中。
for (int i = 0; i < TASK_MAX; i++) {
Runnable myRunnable = new MyRunnable("task [ " + i + " ]");
try {
pool.execute(myRunnable);
} catch (Exception e) {
System.out.println(e.toString());
}
}
// 关闭线程池
pool.shutdown();
}
}
运行结果：
可见0任务到池子之后，运行，剩下1-9在来池子的时候，没位置了，都的排队，但位置就1个，那每次新来的都会不客气但把旧时代的给挤掉。也就是这个策略的名字的由来。
/**
* DiscardOldestPolicy -- 当任务添加到线程池中被拒绝时，线程池会放弃等待队列中最旧的未处理任务，然后将被拒绝的任务添加到等待队列中。
* 结果说明：线程池pool的"最大池大小"和"核心池大小"都为1(THREADS_SIZE)，这意味着"线程池能同时运行的任务数量最大只能是1"。
* 线程池pool的阻塞队列是ArrayBlockingQueue，ArrayBlockingQueue是一个有界的阻塞队列，ArrayBlockingQueue的容量为1。这也意味着线程池的阻塞队列只能有一个线程池阻塞等待。
* 根据""中分析的execute()代码可知：线程池中共运行了2个任务。第1个任务直接放到Worker中，通过线程去执行；第2个任务放到阻塞队列中等待。其他的任务都被丢弃了！
*
* @author yk on 2020/3/27
*/
public class TestDiscardPolicy {
private static final int THREADS_SIZE = 1;
private static final int TASK_MAX = 10;
private static final int CAPACITY = 1;
public static void main(String[] args) throws Exception {
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("Test-Rejected-Policy-Pool-%d").build();
// 创建线程池。线程池的"最大池大小"和"核心池大小"都为1(THREADS_SIZE)，"线程池"的阻塞队列容量为1(CAPACITY)。
ThreadPoolExecutor pool = new ThreadPoolExecutor(THREADS_SIZE, THREADS_SIZE, 0, TimeUnit.SECONDS,
new ArrayBlockingQueue<Runnable>(CAPACITY), namedThreadFactory);
// 设置线程池的拒绝策略为"丢弃"
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
// 新建10个任务，并将它们添加到线程池中。
for (int i = 0; i < TASK_MAX; i++) {
Runnable myRunnable = new MyRunnable("task [ " + i + " ]");
try {
pool.execute(myRunnable);
} catch (Exception e) {
System.out.println(e.toString());
}
}
// 关闭线程池
pool.shutdown();
}
}
5、自定义线程池
/**
* 当线程池耗尽时，由调用者负责执行任务，并打印相关日志
*/
public class CallerRunsWithLogPolicy implements RejectedExecutionHandler {
private static final Logger log = LoggerFactory.getLogger(CallerRunsWithLogPolicy.class);
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
log.error("线程池耗尽,本任务由调用方执行!");
r.run();
}
}
}
运行结果：
任务0来了池子，先抢占了线程，可以执行，之后来的都的在队列里排队，但队列就一个位置，先来的占着位置，后面的来只能看着，被无情的抛弃，所以，输出结果就0，1两个任务执行，其它的都消失了。
最后：
1，几个代码都是创建了一个 "最大池大小"和"核心池大小"都为1 的线程池，意味着"线程池能同时运行的任务数量最大只能是1"
2，创建线程池的时候，应该使用 ThreadPoolExecutor 这个构造函数，可以牢记复习线程池创建原理，另外还的使用带factory参数的构造函数，可以设置池子中的线程的名称，出问题的时候，也好排查。
参考：
https://blog.csdn.net/qq_27093465/article/details/105248633
https://blog.csdn.net/ye17186/article/details/89467919
标签：static,策略,拒绝,任务,线程,new,SIZE,ThreadPoolExecutor 来源： https://www.cnblogs.com/yk775879106/p/16638542.html