一、线程池的优点
1.重用线程池中的线程,可以避免因为线程的创建和销毁所带来的性能开销;
2.能有效的控制线程的最大并发数,避免大量的线程之间因为互相抢占系统资源而导致的阻塞现象。
3.能够对线程进行简单的管理,并提供定时执行已经制定间隔循环执行的等功能。
二、线程池的实现
Android中的线程池的概念来源于Java中的Executor,Executor是一个接口,正在的线程池的实现为ThreadPoolExecutor,它提供了一系列参数来配置线程池,通过不同的参数可以创建不同的线程池。
/**
* 创建线程池
* @param corePoolSize 核心线程数:会在线程池中一直存活,即使是处于闲置状态。
* @param maxPoolSize 最大线程数:当活动线程达到这个数值后,后续的新任务将会被阻塞。
* @param keepAliveTime 非核心线程闲置时的超时时长:超过这个时间非核心线程会被回收
* @param unit 超时时长的时间单位
* @param workQueue 线程池中的任务队列:通过线程池的execute方法提交的Runnable对象会存储在这个参数中。
* @param threadFactory 线程工厂:为线程池提供创建新线程的功能。
*/
new ThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime, TimeUnit unit, BlockingDeque<Runnable> workQueue, ThreadFactory threadFactory)
三、Android中常见的4类线程池
从线程池的功能特性上来说,Android的线程池分为4类,这4类线程池可以通过Executors所有提供的工厂方法来得到。
线程池名称 | FixedThreadPool | CachedThreadPool | ScheduedThreadPool | SingleThreadPool |
---|---|---|---|---|
线程数量 | 固定数量,只有核心线程 | 数量不定,只有非核心线程 | 数量不定,核心线程数量固定,非核心线程不定 | 只有一个核心线程 |
特点 | 1.当所有的线程都处于活动状态时,新的任务会处于等待状态,直到有线程空闲出来; 2.当线程处于空闲状态时,它们并不会被回收,除非线程池被关闭 |
1.当线程池中的所有线程都处于活动状态时,线程池会创建新的线程来处理新的任务,这导致所有的任务都会立即被执行; 2.当线程池闲置时,所有的线程都会因为超时而停止,此时线程池中没有线程,几乎不占用系统资源 |
非核心线程闲置时会被立即回收 | 能确保所有的任务都在同一个线程中按顺序执行 |
优点 | 可以快速的响应外界的请求 | 适合执行大量的耗时少的任务 | 主要用于执行定时任务和具有固定周期的任务 | 统一所有的外界任务到一个线程中,这使得在这些任务之间不需要处理线程同步的问题 |
四、线程池的使用
/**
* 线程池的使用
*/
private void showUsageOfThreadPool(){
/**
* 创建一个任务
*/
Runnable task=new Runnable() {
@Override
public void run() {
SystemClock.sleep(1000);
}
};
/**
* 1. fixedThreadPool 线程池
*/
ExecutorService fixedThreadPool=Executors.newFixedThreadPool(4);
fixedThreadPool.execute(task);
/**
* 2. cachedThreadPool 线程池
*/
ExecutorService cachedThreadPool=Executors.newCachedThreadPool();
cachedThreadPool.execute(task);
/**
* 3. scheduledThreadPool 线程池
*/
ScheduledExecutorService scheduledThreadPool=Executors.newScheduledThreadPool(4);
//延迟2000毫秒之后执行
scheduledThreadPool.schedule(task,2000,TimeUnit.MILLISECONDS);
//延迟100毫秒并以1000毫秒的间隔执行
scheduledThreadPool.scheduleAtFixedRate(task,100,1000,TimeUnit.MILLISECONDS);
/**
* 4. singleThreadExecutor 线程池
*/
ExecutorService singleThreadExecutor=Executors.newSingleThreadExecutor();
singleThreadExecutor.execute(task);
}