线程池
作用
管理线程、减少内存的消耗
ThreadPoolExecutor
创建方式:通过new创建
构造方法
代码语言:javascript复制public ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler
)
int corePoolSize
就是线程池中的核心线程数量,这几个核心线程,在没有用的时候,也不会被回收 =一直开着
int maximumPoolSize
就是线程池中可以容纳的最大线程的数量
当线程池中的线程数等于 corePoolSize 并且 workQueue 已满,这时就要看当前线程数是否大于 maximumPoolSize,如果小于maximumPoolSize 定义的值,则会继续创建线程去执行任务, 否则将会调用去相应的任务拒绝策略来拒绝这个任务。
long keepAliveTime
就是线程池中除了核心线程之外的其他的最长可以保留的时间,因为在线程池中,除了核心线程即使在无任务的情况下也不能被清除,其余的都是有存活时间的,意思就是非核心线程可以保留的最长的空闲时间,
TimeUnit unit
时间的一个单位
代码语言:javascript复制TimeUnit.DAYS; //天
TimeUnit.HOURS; //小时
TimeUnit.MINUTES; //分钟
TimeUnit.SECONDS; //秒
TimeUnit.MILLISECONDS; //毫秒
TimeUnit.MICROSECONDS; //微妙
TimeUnit.NANOSECONDS; //纳秒
BlockingQuue<Runnable> workQueue
就是等待队列,任务可以储存在任务队列中等待被执行,执行的是FIFIO原则(先进先出);直接new
代码语言:javascript复制1)ArrayBlockingQueue //基于数组的先进先出队列,此队列创建时必须指定大小;
2)LinkedBlockingQueue //基于链表的先进先出队列,如果创建时没有指定此队列大小,则默认为Integer.MAX_VALUE;
3)synchronousQueue //这个队列比较特殊,它不会保存提交的任务,而是将直接新建一个线程来执行新来的任务。
ThreadFactory threadFactory
就是创建线程的线程工厂
代码语言:javascript复制Executors.defaultThreadFactory()//默认线程工厂,你想用其他的要导入其他的jar包
RejectedExecutionHandler handler
当线程池的缓存队列已满并且线程池中的线程数目达到maximumPoolSize,如果还有任务到来就会采取任务拒绝策略
代码语言:javascript复制new ThreadPoolExecutor.AbortPolicy: // 丢弃任务并抛RejectedExecutionException异常。
new ThreadPoolExecutor.DiscardPolicy:// 也是丢弃任务,但是不抛出异常。
new ThreadPoolExecutor.DiscardOldestPolicy:// 丢弃队列最前面的任务,然后重新尝试执行(重复此过程)
new ThreadPoolExecutor.CallerRunsPolicy:// 由调用线程处理该任务是一种拒绝策略,我们可以在任务满了之后,拒绝执行某些任务
第一种AbortPolicy:不执行新任务,直接抛出异常,提示线程池已满
第二种DisCardPolicy:不执行新任务,也不抛出异常
第三种DisCardOldSetPolicy:将消息队列中的第一个任务替换为当前新进来的任务执行
第四种CallerRunsPolicy:直接调用execute来执行当前任务
常用方法
execute():提交任务交给线程池运行 不需要运行结果的你就用execute()
submit():提交任务,能够返回执行结果execute Future需要运行结果的你就用submit(),当然你要想获取返回值在里面传入的就是callable类型的对象了还要再Callable里定义返回参数了
shutdown():不能再往线程池中添加任何任务 否则就抛异常,关闭线程池,等待任务都执行完,包括队列中的
shutdownNow():关闭线程池,不等待任务执行完。执行该方法,线程池的状态立刻变成STOP状态,并试图停止(interrupt()方法)所有正在执行的线程,不再处理还在池队列中等待的任务。
getTaskCount():线程池已执行和未执行的任务总数
getCompletedTaskCount():已完成的任务数量
getPoolSize():线程池当前线程数量
getActiveCount():当前线程池中正在执行任务的线程数量
池这个概念?
其他的线程池
创建方式:Executors类方法点出来的,一般用ExecutorService去接
CachedThreadPool
可缓存的线程池,该线程池中没有核心线程,非核心线程的数量为Integer.max_value,就是无限大,当有需要时创建线程来执行任务,没有需要时回收线程,适用于耗时少,任务量大的情况。
本质上是ThreadPoolExecutor的特定参数
SecudleThreadPool
周期性执行任务的线程池,按照某种特定的计划执行线程中的任务,有核心线程,但也有非核心线程,非核心线程的大小也为无限大。适用于执行周期性的任务。
SingleThreadPool
只有一条线程来执行任务,适用于有顺序的任务的应用场景。
FixedThreadPool
定长的线程池,有核心线程,核心线程的即为最大的线程数量,没有非核心线程 本质上是ThreadPoolExecutor的特定参数
使用举例
代码语言:javascript复制 ThreadPoolExecutor executor = new ThreadPoolExecutor(4, 10, 10, TimeUnit.MINUTES, new LinkedBlockingDeque<>(3),
Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());
AscThread ascThread = new AscThread(100);
for (int i = 0; i < 10; i ) {
executor.execute(ascThread);
}
}