Android线程—线程池

2016-07-08 本文已影响258人晴明_

本文内容基于《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

本人技术有限，欢迎指正，谢谢！