android 线程池
2019-10-10 本文已影响0人
吃瓜群众666
一、线程池的优点
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);
}
