欢迎使用CSDN-markdown编辑器

对于很多程序员来说，刚使用Thread的话，通常就是直接new Thread（），不过这样可能会导致一个OOM（内存溢出的问题），使程序奔溃。因此Android提供了一个ThreadPoolExecutor用来让我们管理线程，现在带大家一起了解一下内部的机制。

## 线程池

* ThreadPoolExecutor的介绍

* Executors工厂类的介绍

ThreadPoolExecutor介绍

基础API的介绍

isShutdown() ： 判断线程池是否关闭

isTerminated() : 判断线程池中任务是否执行完成

shutdown() : 调用后不再接收新任务，如果里面有任务，就执行完

shutdownNow() : 调用后不再接受新任务，如果有等待任务，移出队列；有正在执行的，尝试停止之

submit() : 提交执行任务

execute() : 执行任务

【submit和execute区别下面会讲】

构造相关的介绍

corePoolSize : 核心工作的线程个数

maximumPoolSize : 最大线程个数

【核心线程个数小于等于最大线程数，例如核心3个，最大为5个。当核心线程数量3个不够用的时候就另外开辟1个，再不够用就再开辟1个，但是总数最多就是5个】

keepAliveTime : 额外线程空闲的时间，就是当额外2个线程不要用到的时候，多久将其销毁。

unit : keepAliveTime的单位

workQueue ： 任务队列参考下文的BlockingQueue

threadFactory : 线程工厂，如何去创建线程的

handler ： 任务队列添加异常的捕捉器，参考 RejectedExecutionHandler

阻塞队列的介绍（BlockingQueue）

阻塞队列，如果BlockingQueue是空的，从BlockingQueue取东西的操作将会被阻断进入等待状态，直到BlockingQueue进了东西才会被唤醒，同样，如果BlockingQueue是满的，任何试图往里存东西的操作也会被阻断进入等待状态，直到BlockingQueue里有空间时才会被唤醒继续操作。

基础API介绍

往队列中加元素的方法

add(E) : 非阻塞方法, 把元素加到BlockingQueue里，如果BlockingQueue可以容纳，则返回true，否则抛出异常。

offer(E) : 非阻塞, 表示如果可能的话，将元素加到BlockingQueue里，即如果BlockingQueue可以容纳，则返回true，否则返回false。

put(E)：阻塞方法， 把元素加到BlockingQueue里，如果BlockingQueue没有空间，则调用此方法的线程被阻断直到BlockingQueue里有空间再继续。

从队列中取元素的方法

poll(time)： 阻塞方法，取走BlockingQueue里排在首位的元素，若不能立即取出，则可以等time参数规定的时间，取不到时返回null。

take()：取走BlockingQueue里排在首位的对象，若BlockingQueue为空，阻断进入等待状态直到BlockingQueue有新的对象被加入为止。

子类介绍

ArrayBlockingQueue ： FIFO 队列，规定大小的BlockingQueue，其构造函数必须带一个int参数来指明其大小

LinkedBlockingQueue：FIFO 队列，大小不定的BlockingQueue，若其构造函数带一个规定大小的参数，生成的BlockingQueue有大小限制，若不带大小参数，所生成的BlockingQueue的大小由Integer.MAX_VALUE来决定。

PriorityBlockingQueue：优先级队列， 类似于LinkedBlockingQueue，但队列中元素非 FIFO, 依据对象的自然排序顺序或者是构造函数所带的Comparator决定的顺序

SynchronousQueue: 交替队列，队列中操作时必须是先放进去，接着取出来，交替着去处理元素的添加和移除

RejectedExecutionHandler介绍

实现的子类介绍

ThreadPoolExecutor.AbortPolicy

当添加任务出错时的策略捕获器，如果出现错误，则直接抛出异常

ThreadPoolExecutor.CallerRunsPolicy

当添加任务出错时的策略捕获器，如果出现错误，直接执行加入的任务

ThreadPoolExecutor.DiscardOldestPolicy

当添加任务出错时的策略捕获器,如果出现错误,移除第一个任务,执行加入的任务

ThreadPoolExecutor.DiscardPolicy

当添加任务出错时的策略捕获器，如果出现错误，不做处理

接下来，我们自己来创建一个线程代理；

1、

package liuqinbin.com.google.manager;

/**
* @项目名: Google
* @包名: liuqinbin.com.google.manager
* @类名: ThreadPoolProxy
* @创建者: 刘钦彬
* @创建时间:2017/8/5 16:42
* @业务描述信息：TODO
*/

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolProxy {
private ThreadPoolExecutor mExecutor;//创建一个线程池
private int                mCorePoolSize;//核心线程
private int                mMaximumPoolSize;//最大线程
private long               mKeepAliveTime;//额外线程存留时间
/**
* 初始化线程去指定
* @param corePoolSize  线程的核心线程数目
* @param maximumPoolSize   线程里面含有的最多线程数目
* @param keepAliveTime 额外线程保持的额外时间
*/
private ThreadPoolProxy(int corePoolSize,int maximumPoolSize,int keepAliveTime) {
this.mCorePoolSize = corePoolSize;
this.mKeepAliveTime = keepAliveTime;
this.mMaximumPoolSize = maximumPoolSize;
}

//execute(Runnable task)和submit(Runnable task)区别：
//有无返回值
public void execute(Runnable task) {

initThreadPoolExecutor();
mExecutor.execute(task);

}
public Future<?> submit(Runnable task){
initThreadPoolExecutor();
return mEx
4000
ecutor.submit(task);

}

/**
* 初始化线程池
*/
private synchronized void initThreadPoolExecutor() {
if (mExecutor == null || mExecutor.isShutdown() || mExecutor.isTerminated()) {

TimeUnit unit = TimeUnit.MILLISECONDS;//毫秒级别
// BlockingQueue<Runnable> workQueue = new
// ArrayBlockingQueue<Runnable>(10);// 阻塞队列
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>();// 阻塞队列
// BlockingQueue<Runnable> workQueue = new
// PriorityBlockingQueue(initialCapacity, comparator);// 优先级队列

// BlockingQueue<Runnable> workQueue = new
// SynchronousQueue<Runnable>();
ThreadFactory threadFactory = Executors.defaultThreadFactory();
RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardPolicy();
mExecutor = new ThreadPoolExecutor(mCorePoolSize,
mMaximumPoolSize,
mKeepAliveTime,
unit,
workQueue,
threadFactory,
handler);
}
}

/**
* 移除任务，cancel（runnable task）会尝试停止thread中的任务
* remove(Runnable task)只会停止workQueue中的任务
* @param task
*/
public void remove(Runnable task)
{
if (mExecutor != null)
{
mExecutor.remove(task);
}
}

}

2、创建一个单例用来管理这个线程代理：

public class ThreadManager {

private static ThreadPoolProxy mLongPool;
private static Object mLongLock = new Object();//造锁
/**
* 获取耗时操作的线程池
* @return
*/
//    public synchronized static ThreadPoolProxy getLongPool() {
//
//        return new ThreadPoolProxy(5, 5, 3000);
//    }

/**
* 获取耗时操作的池子
* @return
*/
public static ThreadPoolProxy getLongPool(){
if (mLongPool==null)
{
synchronized (mLongLock)
{
if (mLongPool == null)
{
mLongPool = new ThreadPoolProxy(5,5,3000);
}
}

}
return mLongPool;
}

当然我们可以使用系统提供的方法来进行线程池管理，不过我们的目的是让大家知道系统是怎么创建线程管理的。

创建一个单例：

public class ThreadManager {

private static ExecutorService executorService;
private static Object mLongLock = new Object();//造锁
/**
* 获取耗时操作的线程池
* @return
*/
//    public synchronized static ThreadPoolProxy getLongPool() {
//
//        return new ThreadPoolProxy(5, 5, 3000);
//    }

/**
* 获取耗时操作的池子
* @return
*/
public static ThreadPoolProxy getLongPool(){
if (executorService==null)
{
synchronized (mLongLock)
{
if (executorService== null)
{
executorService= Executors.newFixedThreadPool(5);//效果是和我们上面的一样的;
}
}

}
return mLongPool;
}