java拒接策略
// 拒绝策略需要实现的接口
// 如果我们想实现自己的拒绝策略实现这个接口就行了
public interface RejectedExecutionHandler {
// 只有一个方法
void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}
java一共内置了4种拒绝策略，让我们逐个看看每个拒绝策略的实现了什么。
1.CallerRunsPolicy(执行者线程执行)
/**
* 在调用者线程直接运行任务
*/
public static class CallerRunsPolicy implements RejectedExecutionHandler {
public CallerRunsPolicy() { }
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
r.run();
}
}
}
2.AbortPolicy(直接抛异常)
public static class AbortPolicy implements RejectedExecutionHandler {
public AbortPolicy() { }
/**
* 当超过最大线程数时，直接抛异常
*/
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
throw new RejectedExecutionException("Task " + r.toString() +
" rejected from " +
e.toString());
}
}
3.DiscardPolicy(直接丢弃)
public static class DiscardPolicy implements RejectedExecutionHandler {
public DiscardPolicy() { }
/**
* 如果超过了最大线程数则直接丢弃，不处理
*/
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
}
}
4.DiscardOldestPolicy(丢弃最久未执行)
public static class DiscardOldestPolicy implements RejectedExecutionHandler {
public DiscardOldestPolicy() { }
/**
* 丢弃最久未执行的任务，即队列中的首个
*/
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
// 从队列中取出第一个
e.getQueue().poll();
// 执行添加进来的任务
e.execute(r);
}
}
}
