线程池原理解析【一】
线程池的优点:
1、线程是稀缺资源,使用线程池可以减少创建和销毁线程的次数,每个工作线程都可以重复使用
2、可以根据系统的承受能力,调整线程池中工作线程的熟练,防止因为消耗过多内存导致服务器崩溃
线程池的创建:
参数详解
corePoolSize:线程池核心线程数量。创建线程池后,默认情况下,线程池中并没有任何线程,而是等待有任务到来才创建线程去执行任务,除非预创建线程,调用prestartAllCoreThreads(),在任务到来之前就创建corePoolSize个线程。当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列中
maximumPoolSize:线程池最大线程数量,表示线程池中最多能创建多少个线程
keepAliveTime:当活跃线程熟大于核心线程数时,空余的多余线程最大的存活时间;只有当线程中的线程数大于corePoolSize时才其作用
unit:存活时间的单位,在TimeUnit类中有7种静态属性
workQueue:存放任务的队列,一个阻塞队列,用来存储等待执行的任务(ArrayBlockingQueue,LinkedBlockingQueue,synchronousQueue)
ArrayBlockingQueue:基于数组的先进先出队列,此队列创建时必须指定大小
LinkedBlockingQueue:j基于链表的先进先出队列,如果创建时没有指定此队列的大小,默认Integer.MAX_VALUE
synchronousQueue:不会保存提交的任务,而是将直接创建一个线程来执行任务
Executor <-继承--ExecutorService <---实现--AbstractExecutorService<--继承-ThreadPoolExecutor
ThreadPoolExecutor主要方法
execute()核心方法,向线程池中提交任务,shutdown()关闭线程池
handler:超出线程范围和队列容量的任务的处理程序
demo案列:
/** * @program: threadpool * @author: xuWei * @create: 2019/03/19 * @description: 线程池实现类 */ public class TestPool { public static void main(String[] args) { ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 200, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(5)); for(int i=0;i<15;i++){ MyTask myTask = new MyTask(i); executor.execute(myTask); System.out.println("线程池中线程数目:"+executor.getPoolSize()+",队列中等待执行的任务数目:"+ executor.getQueue().size()+",已执行玩别的任务数目:"+executor.getCompletedTaskCount()); } executor.shutdown(); } } class MyTask implements Runnable { private int taskNum; public MyTask(int num) { this.taskNum = num; } @Override public void run() { System.out.println("正在执行task "+taskNum); try { Thread.currentThread().sleep(4000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("task "+taskNum+"执行完毕"); } }
返回结果: