在日常开发过程中总是以单线程的思维去编码,没有考虑到在多线程状态下的运行状况。由此引发的结果就是请求过多,应用无法响应。为了解决请求过多的问题,又衍生出了线程池的概念。通过“池”的思想,从而合理的处理请求。本文记录了Java中线程池的使用及工作原理,如有错误,欢迎指正。总结了一张Java多线程图谱分享给大家:
什么是线程池?
线程池是一种用于实现计算机程序并发执行的软件设计模式。线程池维护多个线程,等待由调度程序分配任务以并发执行,该模型提高了性能,并避免了由于为短期任务频繁创建和销毁线程而导致的执行延迟。
线程池要解决什么问题?说到线程池就一定要从线程的生命周期讲起。
从图中可以了解无论任务执行多久,每个线程都要经历从生到死的状态。而使用线程池就是为了避免线程的重复创建,从而节省了线程的New至Runnable, Running至Terminated的时间;同时也会复用线程,最小化的节省系统资源,于此同时提高了响应速度。
线程池的使用线程池的创建使用ThreadPoolExecutor并配置7个参数完成线程池的创建
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
corePoolSize线程池中核心线程的最大值
maximumPoolSize线程池中最大线程数
keepAliveTime非核心线程空闲的存活时间大小
unitkeepAliveTime的单位,常用的有秒、分钟、小时等
workQueue阻塞队列类型
threadFactory线程工厂,用于配置线程的名称,是否为守护线程等
handler线程池的拒绝策略
常用阻塞队列ArrayBlockingQueue底层基于数组的实现的有界阻塞队列
LinkedBlockingQueue 底层基于单链表的阻塞队列,可配置容量,不配置容量默认为Integer.MAX_VALUE
线程工厂在《阿里巴巴Java开发手册》中强制要求指定线程的名称
由于工作是使用hutool比较多,里面也包含对ThreadFactory的封装,可以很方便的指定名称
ThreadFactory threadFactory = ThreadFactoryBuilder.create().setNamePrefix("myThread-").build();
拒绝策略当线程池内工作线程数大于maximumPoolSize时,线程就不再接受任务,执行对应的拒绝策略;目前支持的拒绝策略有四种:
1.AbortPolicy(默认):丢弃任务并抛出RejectedExecutionException异常
2.CallerRunsPolicy:由调用者处理
3.DiscardOldestPolicy:丢弃队列中最前面的任务,并重新入队列
4.DiscardPolicy:丢弃任务但不抛出异常
线程池的执行逻辑execute()方法
// 创建线程工厂 ThreadFactory threadFactory = ThreadFactoryBuilder.create().setNamePrefix("myThread-").build(); // 创建线程池 ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 10, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100), threadFactory, new ThreadPoolExecutor.AbortPolicy());
// 组合值;保存了线程池的工作状态和工作线程数 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
执行流程
public void execute(Runnable command) { // 任务为空 抛出NPE if (command == null) throw new NullPointerException(); // 获取线程池状态 int c = ctl.get(); // 如果工作线程数小于核心线程数就创建新线程 if (workerCountOf(c) < corePoolSize) { if (addWorker(command, true)) return; c = ctl.get(); } // 如果线程池处于Running状态,就把任务放在队列尾部 if (isRunning(c) && workQueue.offer(command)) { // 重新检查线程池状态 int recheck = ctl.get(); // 如果线程池不是Running状态,就移除刚才添加的任务,并执行拒绝策略 if (! isRunning(recheck) && remove(command)) reject(command); // 是Running状态,就添加线程 else if (workerCountOf(recheck) == 0) addWorker(null, false); } // 添加任务失败,执行拒绝策略 else if (!addWorker(command, false)) reject(command); } // addWorker()完成线程的创建
watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=
最后
另外还整理成了40多套PDF文档:全套的Java面试宝典手册,“性能调优 微服务架构 并发编程 开源框架 分布式”等七大面试专栏,包含Tomcat、JVM、MySQL、SpringCloud、SpringBoot、Dubbo、并发、Spring、SpringMVC、MyBatis、Zookeeper、Ngnix、Kafka、MQ、Redis、MongoDB、memcached等等。如果你对这个感兴趣,小编可以免费分享。
资料获取方式:关注小编 转发文章 私信【面试题】获取上述资料~
重要的事情说三遍,转发 转发 转发,一定要记得转发哦!!
,