当我们使用 线程池的时候，可以使用 newcachedthreadpool（）或者 newfixedthreadpool(int)等方法，其实我们深入到这些方法里面，就可以看到它们的是实现方式是这样的。
|
1
2
3
4
5
|
public static executorservice newcachedthreadpool() {
return new threadpoolexecutor(0, integer.max_value,
60l, timeunit.seconds,
new synchronousqueue<runnable>());
}
|
|
1
2
3
4
5
|
public static executorservice newfixedthreadpool(int nthreads) {
return new threadpoolexecutor(nthreads, nthreads,
0l, timeunit.milliseconds,
new linkedblockingqueue<runnable>());
}
|
包括其他几种不同类型的线程池，其实都是通过 threadpoolexecutor这个核心类来创建的，如果我们要自定义线程池，那么也是通过这个类来实现的。
该类有四个构造方法，查看源码可以看到，头三个构造方法，其实都是调用的第四个构造方法，所以我们就解释一下第四个构造方法的参数含义。
|
1
2
3
4
5
6
7
|
public threadpoolexecutor(int corepoolsize,
int maximumpoolsize,
long keepalivetime,
timeunit unit,
blockingqueue<runnable> workqueue,
threadfactory threadfactory,
rejectedexecutionhandler handler)
|
corepoolsize：核心线程池的大小，在线程池被创建之后，其实里面是没有线程的。（当然，调用prestartallcorethreads()或者prestartcorethread()方法会预创建线程，而不用等着任务的到来）。当有任务进来的时候，才会创建线程。当线程池中的线程数量达到corepoolsize之后，就把任务放到 缓存队列当中。（就是 workqueue）。
maximumpoolsize：最大线程数量是多少。它标志着这个线程池的最大线程数量。如果没有最大数量，当创建的线程数量达到了 某个极限值，到最后内存肯定就爆掉了。
keepalivetime：当线程没有任务时，最多保持的时间，超过这个时间就被终止了。默认情况下，只有 线程池中线程数量 大于 corepoolsize时，keepalivetime值才会起作用。也就说说，只有在线程池线程数量超出corepoolsize了。我们才会把超时的空闲线程给停止掉。否则就保持线程池中有 corepoolsize 个线程就可以了。
unit：参数keepalivetime的时间单位，就是 timeunit类当中的几个属性。
如下图：
workqueue：用来存储待执行任务的队列，不同的线程池它的队列实现方式不同（因为这关系到排队策略的问题）比如有以下几种
arrayblockingqueue：基于数组的队列，创建时需要指定大小。
linkedblockingqueue：基于链表的队列，如果没有指定大小，则默认值是 integer.max_value。（newfixedthreadpool和newsinglethreadexecutor使用的就是这种队列）。
synchronousqueue：这种队列比较特殊，因为不排队就直接创建新线程把任务提交了。（newcachedthreadpool使用的就是这种队列）。
threadfactory:线程工厂，用来创建线程。
handler：拒绝执行任务时的策略，一般来讲有以下四种策略，
（1） threadpoolexecutor.abortpolicy 丢弃任务，并抛出 rejectedexecutionexception 异常。
（2） threadpoolexecutor.callerrunspolicy：该任务被线程池拒绝，由调用 execute方法的线程执行该任务。
（3） threadpoolexecutor.discardoldestpolicy ： 抛弃队列最前面的任务，然后重新尝试执行任务。
（4） threadpoolexecutor.discardpolicy，丢弃任务，不过也不抛出异常。
看一个demo ，示例代码地址：src/thread_runnable/customthreadpool.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
class customtask implements runnable{
private int id;
public customtask(int id) {
this.id = id;
}
@override
public void run() {
// todo auto-generated method stub
system.out.println("#" + id + " threadid=" + thread.currentthread().getname() );
try {
timeunit.milliseconds.sleep(100);
}catch(interruptedexception e){
e.printstacktrace();
}
}
}
public class customthreadpool {
public static void main(string[] args) {
// todo auto-generated method stub
blockingqueue<runnable> queue = new arrayblockingqueue<>(10);
threadpoolexecutor pool = new threadpoolexecutor(3, 5, 60, timeunit.microseconds, queue);
for (int i=0; i<7; i++){
runnable task = new customtask(i);
pool.execute(task);
}
pool.shutdown();
}
}
|
输出结果：
从这个例子，可以看出，虽然我们有7个任务，但是实际上，只有三个线程在运行。
那么当我们提交任务给线程池之后，它的处理策略是什么呢？
（1），如果当前线程池线程数目小于 corepoolsize（核心池还没满呢），那么就创建一个新线程去处理任务。
（2），如果核心池已经满了，来了一个新的任务后，会尝试将其添加到任务队列中，如果成功，则等待空闲线程将其从队列中取出并且执行，如果队列已经满了，则继续下一步。
（3），此时，如果线程池线程数量 小于 maximumpoolsize，则创建一个新线程执行任务，否则，那就说明线程池到了最大饱和能力了，没办法再处理了，此时就按照拒绝策略来处理。（就是构造函数当中的handler对象）。
（4），如果线程池的线程数量大于corepoolsize，则当某个线程的空闲时间超过了keepalivetime，那么这个线程就要被销毁了，直到线程池中线程数量不大于corepoolsize为止。
举个通俗易懂的例子，公司要设立一个项目组来处理某些任务，hr部门给的人员编制是10个人（corepoolsize）。同时给他们专门设置了一间有15个座位（maximumpoolsize）的办公室。最开始的时候来了一个任务，就招聘一个人。就这样，一个一个的招聘，招满了十个人，不断有新的任务安排给这个项目组，每个人也在不停的接任务干活。不过后来任务越来越多，十个人无法处理完了。其他的任务就只能在走廊外面排队了。后来任务越来越多，走廊的排队队伍也挤不下。然后只好找找一些临时工来帮助完成任务。因为办公室只有15个座位，所以它们最多也就只能找5个临时工。可是任务依旧越来越多，根本处理不完，那没办法，这个项目组只好拒绝再接新任务。（拒绝的方式就是 handler），最后任务渐渐的少了，大家都比较清闲了。所以就决定看大家表现，谁表现不好，谁就被清理出这个办公室（空闲时间超过 keepalivetime），直到 办公室只剩下10个人（corepoolsize），维持固定的人员编制为止。
关于线程池，threadpoolexecutor还提供了一些需要注意的方法：
（1） shutdown()，平滑的关闭线程池。（如果还有未执行完的任务，就等待它们执行完）。
（2） shutdownnow()。简单粗暴的关闭线程池。（没有执行完的任务也直接关闭）。
（3） setcorepoolsize()。设置/更改核心池的大小。
（4） setmaximumpoolsize（），设置/更改线程池中最大线程的数量限制。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。
原文链接：http://www.cnblogs.com/yaoxiaowen/p/6576898.html