上一篇文章已经介绍了线程的基本概念以及线程相关的API，下面来看一下线程池

一、线程池框架

1、线程池的优点

重用线程池中的线程，避免因为线程的创建和销毁所带来的性能开销。 

能有效控制线程池的最大并发数，避免大量线程之间因互相抢夺系统资源而导致的阻塞现象。 

能够对线程进行简单的管理，并提供定时执行以及指向间隔循环执行等功能。

2、JAVA中相关类

Executor是一个顶层接口，它里面只声明了一个方法execute(Runnable)

ExecutorService接口继承了Executor接口，并且声明了一些方法：submit、invokeAll、invokeAny以及shutDown等AbstractExecutorService实现了ExecutorService接口，基本实现了ExecutorService中声明的所有方法

ThreadPoolExecutor接口继承了AbstractExecutorService这个类，并且实现了这些重要方法：execute() 、shutdown()、shutdownNow()

Executors提供了大量的static方法，来创建各种特性的线程池（基于ThreadPoolExecutor的构造方法）、大量的callable方法和创建ThreadFactory的方法

ThreadPoolExecutor的重要属性

private final BlockingQueue<Runnable> workQueue;//任务缓存队列，用来存放等待执行的任务private final ReentrantLock mainLock = new ReentrantLock();//线程池的主要状态锁，对线程池状态（比如线程池大小、runState等）的改变都要使用这个锁private final HashSet<Worker> workers = new HashSet<Worker>();//用来存放工作集private final Condition termination = mainLock.newCondition();//private int largestPoolSize;//用来记录线程池中曾经出现过的最大线程数private long completedTaskCount;//用来记录已经执行完毕的任务个数private volatile ThreadFactory threadFactory;//线程工厂，用来创建线程private volatile RejectedExecutionHandler handler;//任务拒绝策略private volatile long keepAliveTime;//线程存活时间 private volatile boolean allowCoreThreadTimeOut;//是否允许为核心线程设置存活时间private volatile int corePoolSize;//核心池的大小（即线程池中的线程数目大于这个参数时，提交的任务会被放进任务缓存队列）private volatile int maximumPoolSize;//线程池最大能容忍的线程数private static final RejectedExecutionHandler defaultHandler =new AbortPolicy();//默认的任务拒绝策略private static final RuntimePermission shutdownPerm =new RuntimePermission("modifyThread");

这里要重点解释一下corePoolSize、maximumPoolSize、largestPoolSize三个变量。

corePoolSize在很多地方被翻译成核心池大小，其实我的理解这个就是线程池的大小。举个简单的例子：

　　假如有一个工厂，工厂里面有10个工人，每个工人同时只能做一件任务。

　　因此只要当10个工人中有工人是空闲的，来了任务就分配给空闲的工人做；

　　当10个工人都有任务在做时，如果还来了任务，就把任务进行排队等待；

　　如果说新任务数目增长的速度远远大于工人做任务的速度，那么此时工厂主管可能会想补救措施，比如重新招4个临时工人进来；

　　然后就将任务也分配给这4个临时工人做；

　　如果说着14个工人做任务的速度还是不够，此时工厂主管可能就要考虑不再接收新的任务或者抛弃前面的一些任务了。

　　当这14个工人当中有人空闲时，而新任务增长的速度又比较缓慢，工厂主管可能就考虑辞掉4个临时工了，只保持原来的10个工人，毕竟请额外的工人是要花钱的。

　　这个例子中的corePoolSize就是10，而maximumPoolSize就是14（10+4）。

　　也就是说corePoolSize就是线程池大小，maximumPoolSize在我看来是线程池的一种补救措施，即任务量突然过大时的一种补救措施。

　　不过为了方便理解，在本文后面还是将corePoolSize翻译成核心池大小。

　　largestPoolSize只是一个用来起记录作用的变量，用来记录线程池中曾经有过的最大线程数目，跟线程池的容量没有任何关系。

重要方法

execute

public void execute(Runnable command) {if (command == null)throw new NullPointerException();int c = ctl.get();if (workerCountOf(c) < corePoolSize) {if (addWorker(command, true))return;c = ctl.get();}if (isRunning(c) && workQueue.offer(command)) {int recheck = ctl.get();if (! isRunning(recheck) && remove(command))reject(command);else if (workerCountOf(recheck) == 0)addWorker(null, false);}else if (!addWorker(command, false))reject(command);}

3、线程池的分类

newFixedThreadPool

newWorkStealingPool

newSingleThreadExecutor

newCachedThreadPool

newSingleThreadScheduledExecutor

newScheduledThreadPool

重点是ThreadPoolExecutor的代码、还需要理解线程池状态、任务的执行、线程池中的线程初始化、任务缓存队列及排队策略、任务拒绝策略、线程池的关闭、线程池容量的动态调整

简单使用Demo

package com.demo;import java.util.ArrayList; import java.util.Collection; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class ThreadPool { private int threadCount = 10;private int threadpoolCount = 3;public static void main(String[] args) {new ThreadPool().threadPoolControl();}public void threadPoolControl() { ThreadObject[] et = new ThreadObject[threadCount]; ExecutorService service = Executors.newFixedThreadPool(threadpoolCount);Collection<ThreadObject> c = new ArrayList<ThreadObject>();for (int i = 0; i < threadCount; i++) { et[i] = new ThreadObject(); c.add(et[i]);}try {service.invokeAll(c);service.shutdown();} catch (InterruptedException e) {e.printStackTrace();}}class ThreadObject implements Callable<Object>{ public Object call() throws Exception {System.out.println("当前线程："+Thread.currentThread().getName()+",线程对象："+this);return null;}} }

 

总结

以上是生活随笔为你收集整理的【JAVA中级篇】线程池的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。