目录
自定义线程池的使用
四种拒绝策略代码体现
1. 自定义线程池的使用
自定义线程池(拒绝策略默认AbortPolicy)
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时执行结果: