AbortPolicy
【摘要】 AbortPolicy（默认）：直接抛出RejectedExecutionException异常阻止系统正常运行。
package com.istudy;
import java.util.concurrent.*;
/**
* @projectname: HelloFlink
* @description:AbortPolicy
* @author: Mr.Zhan...
AbortPolicy（默认）：直接抛出RejectedExecutionException异常阻止系统正常运行。
package com.istudy;
import java.util.concurrent.*;
/**
* @projectname: HelloFlink
* @description:AbortPolicy
* @author: Mr.Zhang
* @create: 2021-04-15 22:39
**/
public class ThreadPoolTest { /** * * @param args */ public static void main(String[] args) { //这里是一个默认的线程池，没有设置拒绝策略，设置了最大线程队列是100。 //线程池的默认拒绝策略为AbortPolicy，即丢弃任务并抛出RejectedExecutionException异常 BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(100); ThreadFactory factory = r -> new Thread(r, "test-thread-pool"); ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 0L, TimeUnit.SECONDS, queue, factory); while (true) { executor.submit(() -> { try { System.out.println(queue.size()); Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } }); } }
}
文章来源: www.jianshu.com，作者：百忍成金的虚竹，版权归原作者所有，如需转载，请联系作者。
原文链接：www.jianshu.com/p/afae09a8fbca
【版权声明】本文为华为云社区用户转载文章，如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）