Java中的线程池(2)----FixedThreadPool

在上篇文章中写了一些线程池基本知识和jdk中提供的一种线程池CachedThreadPool，本文简单说明FixedThreadPool这一线程池。

创建FixedThreadPool的静态方法

首先还是先看一下创建FixedThreadPool的静态方法：

public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}

观察其构造参数可以发现：

1、它是一个固定线程个数的线程池，因为初始化参数当中corePoolSize和maximumPoolSize都是nThreads，这就意味着线程池中线程个数固定；

2、keepAliveTime为0，然而这个地方这个属性没有意义，因为都不会存在maximumPoolSize>corePoolSize的情况；

3、阻塞队列使用了LinkedBlockingQueue，是一个无界队列，以此永远不可能拒绝任务。

LinkedBlockingQueue

LinkedBlockingQueue在入队列和出队列时使用的是不同的Lock，意味着他们之间不存在互斥关系，在多CPU情况下，他们能正在在同一时刻既消费，又生产，真正做到并行。

现在回过头来思考FixedThreadPool，前面说过他的特点在于这种线程池的线程个数是固定的，而且阻塞队列是可以存储任务的，因此这种线程池不会拒绝任务，而且不会开辟新的线程，也不会因为线程的长时间不使用而销毁线程。这是典型的生产者----消费者问题，这种线程池适合用在稳定且固定的并发场景，比如服务器。让我们来做一下代码测试，在Test类中进行测试：

package newFixedThreadPool;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Test {
public static void main(String[] args) {
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
int i = 0;
while (i++<10) {
fixedThreadPool.execute(new Runnable() {
@Override
public void run() {
System.out.println(Thread.current
4000
Thread().getName() + "执行");
try {
Thread.sleep(3000);//模拟当前线程执行其他操作 花费3s
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
fixedThreadPool.shutdown();
}
}

运行结果如下：



由于线程池只有3个线程，而且不能新开辟线程，所以当新的请求到来的时候由于不能马上处理这些请求，只能在LinkedBlockingQueue类型的阻塞队列中进行等待，直到有新的线程可以使用才开始处理之前被阻塞的请求。