线程池的底层原理
Executors源码:
public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); } public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>())); } public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); } public ThreadPoolExecutor(int corePoolSize, //线程池中的常驻核心线程数 int maximumPoolSize, //线程池能容纳同时执行的最大线程数,此值必须大于等于1 long keepAliveTime, //多余的空闲线程的存活时间,当前池中线程数量超过corePoolSize时,当空闲时间达到keepAliveTime时,多余线程就会被销毁到只剩下corePoolSize为止 TimeUnit unit, //keepAliveTime的单位 BlockingQueue<Runnable> workQueue, //任务队列,被提交但尚未执行的任务 ThreadFactory threadFactory, //创建线程的工厂,默认即可 RejectedExecutionHandler handler //拒绝策略,当队列满(maximumPoolSize)时,根据该handler决定如何拒绝请求执行的runnable ) { ..... .... ... }
线程池工作原理:
线程池工作图解析:
线程池工作流程:
线程池工作流程:
1、在创建了线程池后,开始等待请求。
2、当调用execute()方法添加一个请求任务时,线程池会做出如下判断:
2.1如果正在运行的线程数量小于corePoolSize,那么马上创建线程运行这个任务;
2.2如果正在运行的线程数量大于或等corePoolSize,那么将这个任务放入队列;
2.3如果这个时候队列满了且正在运行的线程数量还小于maximumPoolSize,那么还是要创建非核心线程立刻运行这个任 务;
2.4如果队列满了且正在运行的线程数量大于或等于maximumPoolSize,那么线程池会启动饱和拒绝策略来执行。
3、当一个线程完成任务时,它会从队列中取下一个任务来执行。
4、当一个线程无事可做超过一定的时间(keepAliveTime)时,线程会判断:
如果当前运行的线程数大于corePoolSize,那么这个线程就被停掉。所以线程池的所有任务完成后,它最终会收缩
corePoolSize的大小。
注意:
在工作中单一的/固定的/可变的三种创建线程池的方法哪个用的多?
答: 一个都不用
OOM java虚拟机内存溢出异常