Java中的线程池

一、使用线程池的好处

a、下降资源消耗。经过重复利用已建立的线程下降线程建立和摧毁形成的消耗；

b、提升响应速度。当任务到达时，任务能够不须要等到线程建立就能当即执行；

c、提升线程的可管理性。线程是稀缺资源，若是无限制地建立，不只会消耗系统资源，还会下降系统的稳定性，使用线程池能够及进行统一分配、调优和监控。

二、线程池的实现原理

当线程池想提交一个任务以后，线程池的主要处理流程如图：

jdk1.8中ThreadPoolExecutor执行execute()方法的源代码以下：

1 public void execute(Runnable command) { 
2 if (command == null)
3 throw new NullPointerException(); 
4 int c = ctl.get();//原子类型AtomicInteger ctl，获取值 
5 if (workerCountOf(c) < corePoolSize) {//判断当前工做线程是否小于核心线程数目 
6 if (addWorker(command, true))//是则建立新的工做线程，并将当前任务传递进去处理后返回结果， 
7 return; 
8 c = ctl.get();//若是失败，继续执行下面的代码进行判断 
9 }
10 if (isRunning(c) && workQueue.offer(command)) {
11 int recheck = ctl.get();
12 if (! isRunning(recheck) && remove(command))
13 reject(command);
14 else if (workerCountOf(recheck) == 0)
15 addWorker(null, false);//加入工做线程
16 }
17 else if (!addWorker(command, false))//建立新的线程，
18 reject(command);
19 }

1 private boolean addWorker(Runnable firstTask, boolean core) { 
2 retry: 
3 for (;;) { 
4 int c = ctl.get(); 
5 int rs = runStateOf(c); 
6 
7 // Check if queue empty only if necessary. 
8 if (rs >= SHUTDOWN && 
9 ! (rs == SHUTDOWN &&
10 firstTask == null &&
11 ! workQueue.isEmpty()))
12 return false;
13
14 for (;;) {
15 int wc = workerCountOf(c);
16 if (wc >= CAPACITY ||
17 wc >= (core ? corePoolSize : maximumPoolSize))
18 return false;
19 if (compareAndIncrementWorkerCount(c))
20 break retry;
21 c = ctl.get(); // Re-read ctl
22 if (runStateOf(c) != rs)
23 continue retry;
24 // else CAS failed due to workerCount change; retry inner loop
25 }
26 }

线程池中的线程执行任务分为两种状况：

a、在execute()方法中建立一个线程时，会让这个线程执行当前任务；

b、在这个线程执行完上述任务后，会反复从BlockingQueue获取任务来执行。

三、线程池的使用

咱们能够经过ThreadPoolExecutor来建立一个线程池。

new ThreadPoolExecutor(int corePoolSize,

int maximumPoolSize,

long keepAliveTime,

TimeUnit unit,

BlockingQueue<Runnable> workQueue,

ThreadFactory threadFactory,

RejectedExecutionHandler handler);

corePoolSize：线程池的基本大小，当提交一个任务到线程池时，线程池会建立一个线程来执行任务，即便其余空闲的基本线程可以执行新任务也会建立线程，等到须要执行的任务数大于线程池基本大小时就再也不建立。若是调用了线程池的prestartAllCoreThreads()方法，线程池会提早建立并启动全部基本线程。

maximumPoolSize：线程池的最大数量，线程池容许建立的最大线程数。若是队列满了，而且已建立的线程数小于最大线程数，则线程池会再建立新的线程执行任务。值得注意的是，若是使用了无界的任务队列这个参数就没什么效果。

KeepAliveTime：线程活动保持时间，线程池的工做线程空闲后，保持存活的时间。

unit：线程活动保持时间的单位，可选的单位有天，小时，分钟，毫秒，微秒，纳秒。

workQueue：任务队列，用来保存等待执行的任务的阻塞队列。在任务被执行以前存储这些任务，工做队列仅存储执行了execute方法的任务。能够选择如下几个阻塞队列：ArrayBlockingQueue，LinkedBlockingQueue，SynchronousQueue和PriorityBlockingQueue。

threadFactory：用于设置建立线程的工厂，能够经过线程工厂给每一个建立出来的线程设置更有意义的名字。

handler：饱和策略，当队列和线程池都满了，说明线程池处于饱和状态，那么必须采起一种策略处理提交的新任务。这个策略默认状况下是AbortPolicty，表示没法处理新任务时抛出异常。

四、向线程池提交任务

可使用两个方法向线程池提交任务，分别是execute()和submit()方法。

execute()方法用于提交不须要返回值的任务，因此没法判断任务是否被线程池执行成功。

submit()方法用于提交须要返回值的任务。线程池会返回一个future类型的对象，经过这个future对象能够判断任务是否执行成功，而且能够经过future的get()方法来获取返回值，get()方法会阻塞当前线程知道任务完成，而使用get(long timeout, TimeUnit unit)方法则会阻塞当前线程一段时间后当即返回，这时候可能任务尚未执行完。

五、关闭线程池

能够经过调用线程池的shutdown或shutdownNow方法来关闭线程池。

原理：遍历线程池中的工做线程，而后逐个调用线程的interrupt方法来中断线程，因此没法响应中断的任务可能永远没法终止。

区别：shutdownNow先将线程池的状态设置成STOP，而后尝试中止全部正在执行或暂停任务的额线程，并返回等待执行任务的列表；

shutdown只是将线程池的状态设置成SHUTDOWN状态，而后中断全部没有正在执行任务的线程。

一般调用shutdown来关闭线程池，若是任务不必定要执行完，则能够调用shutdownNow方法。

建议使用有界队列：能增长系统的稳定性和预警能力。