java线程-线程池原理
1.如何创建线程池
//创建一个线程的线程池
ExecutorService singleExecutor=Executors.newSingleThreadExecutor();
//创建一个固定数量的线程池
ExecutorService fixedExecutor=Executors.newFixedThreadPool(5);
//创建一个线程池,线程最大数量为Integer.Max
ExecutorService cachedExecutor=Executors.newCachedThreadPool();
//创建线程池,可做定时调度
ExecutorService scheduldExecutor=Executors.newScheduledThreadPool(500);
//通过ThreadPoolExecutor创建线程
new ThreadPoolExecutor();
2.线程池参数分析
public ThreadPoolExecutor(int corePoolSize,//核心线程书
int maximumPoolSize,//最大线程数
long keepAliveTime,//非核心线程数的存活时间
TimeUnit unit,//存活单位
BlockingQueue<Runnable> workQueue//阻塞队列) {
this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
Executors.defaultThreadFactory(), defaultHandler);
}
3.线程池原理
当提交一个新任务到线程池时首先线程池判断基本线程池(corePoolSize)是否已满?没满,创建一个工作线程来执行任务。满了,则进入下个流程;其次线程池判断工作队列(workQueue)是否已满?没满,则将新提交的任务存储在工作队列里。满了,则进入下个流程;最后线程池判断整个线程池(maximumPoolSize)是否已满?没满,则创建一个新的工作线程来执行任务,满了,则交给饱和策略来处理这个任务;如果线程池中的线程数量大于 corePoolSize 时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过 keepAliveTime,线程也会被终止。
饱和策略:
Abort策略:默认策略,新任务提交时直接抛出未检查的异常RejectedExecutionException,该异常可由调用者捕获。
CallerRuns策略:为调节机制,既不抛弃任务也不抛出异常,而是将某些任务回退到调用者。不会在线程池的线程中执行新的任务,而是在调用exector的线程中运行新的任务。
Discard策略:新提交的任务被抛弃。