本文内容基于《Android开发艺术探索》,强烈推荐,值得一看。
1.优点
为什么要用线程池,概括来说有以下三点原因:
1. 避免重复创建和销毁线程带来的性能开销;
2. 控制最大并发数,避免因为大量线程抢占系统资源导致阻塞;
3. 对线程进行管理,并提供定时执行以及指定间隔循环执行等功能。
2.ThreadPoolExecutor
Android中的线程池来自于Java的Executor,它是一个接口,真正的实现是ThreadPoolExecutor类。 ThreadPoolExecutor提供了一系列参数来配置线程池,通过不同参数来创建不同的线程池,注意可以分为4类,稍后再做具体介绍,下面我们先来分析一下ThreadPoolExecutor,ThreadPoolExecutor有多个构造器,这里我们只介绍常用的一种
public ThreadPoolExecutor( int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue
ThreadFactory threadFactory)
corePoolSize:
线程池核心线程数,默认情况下即使处于闲置状态也会一直存活(如果吧allowCoreThreadTimeOut设置为true,那么闲置的核心线程会有超时策略,当等到超过keepAliveTime所指定的时间后会被停止);
maximumPoolSize:
线程池所能容纳的最大线程数,当活动线程达到这个数后后续新任务将会被阻塞;
keepAliveTime:
非核心线程的闲置超时时长,当等到超过keepAliveTime所指定的时间后闲置的线程会被停止(如果吧allowCoreThreadTimeOut设置为true,那么闲置的核心线程会有超时策略,当等到超过keepAliveTime所指定的时间后会被停止);
unit:
用来指定keepAliveTime的时间单位,是个枚举;
workQueue:
线程池的任务队列,通过线程池的execute方法提交的Runnable对象会存储在这个参数中;
threadFactory:
线程工厂,为线程池提供创建新线程的功能,ThreadFactory是一个接口,只有一个方法:ThreadFactory.newThread(runnable)。
除了上面几个主要参数,还有一个不常用的参数RejectedExecutionHandler handler如下面所示的构造方法,当线程池无法执行新任务时(人物队列已满或者无法成功执行任务),会调用handler的rejectedExecution方法通知调用着,默认情况下rejectedExecution会抛出一个异常,ThreadPoolExecutor提供了几个可选值,因为不常有这里就不做介绍了。
public ThreadPoolExecutor( int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
ThreadPoolExecutor执行任务时大致遵循的规则如下,假设线程池中的实际线程数为n:
1). 当n<corePoolSize时,会启动一个核心线程执行任务;
2). 当corePoolSize=<n<maximumPoolSize时,任务会插入到workQueue等到执行;
3). 当corePoolSize=<n<maximumPoolSize时,如果无法插入workQueue(可能workQueue已满)时会立刻启动一个非核心线程来执行任务;
4).当n>=maximumPoolSize时,会拒绝执行任务并调用RejectedExecutionHandler的rejectedExecution方法通知调用者。
3.常见线程池
1). FixedThreadPool:
Executors.newFixedThreadPool(nThreads) //创建
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
}
这是一种固定数量的线程池,而且所有线程都是核心线程,即使空闲也不会被回收,除非线程池被关闭。当所有的线程都处于活动状态,没有闲置的线程时,如果有新任务过来,会处于等待状态。优点:可以更迅速的响应外界的请求,任务队列没有大小闲置。
2). CachedThreadPool:
Executors.newCachedThreadPool() //创建
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>());
}
这是一种线程数量不定的线程池,所有的线程都是非核心线程,并且非核心线程的数量为Integer.MAX_VALUE(基本是算数没有上限)。当所有的线程都处于活动状态,如果有新任务过来,就会创建新的线程去执行新的任务。TimeUnit为60秒,当空闲的线程超过60秒还是空闲,将会被回收。由于会进行回收,所以几乎不怎么占用系统资源,适用于执行大量的耗时较少的任务
3). ScheduledThreadPool:
Executors.newScheduledThreadPool() //创建
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize){
return new ScheduledThreadPoolExecutor(corePoolSize);
}
public ScheduledThreadPoolExecutor(int corePoolSize) {
super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS, new DelayedWorkQueue());
}
这是一种核心线程数量固定的线程池,非核心线程数量没有上限。并且非核心线程如果空闲会很快被回收。
适用于执行定时任务和具有固定周期的重复任务。
4). SingledThreadPool:
Executors.newSingleThreadExecutor() //创建
public static ExecutorService newSingleThreadExecutor() {
return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()));
}
这个线程池核心线程有且只有一个,并且不会被回收。它确保所有的任务都在同一个线程中按顺序执行。它可以统一所有的外界任务在同一个线程中按顺序执行,使得这些线程之间不需要解决线程同步的问题。
4.应用
可参考http://www.importnew.com/8542.html
本人技术有限,欢迎指正,谢谢!
网友评论