线程池可以吞掉异常

线程池很好的帮助开发者解决了线程复用的问题，同时也提供了很好的容错性，然而有的时候帮我们做了很多的事情，如果发生了异常会造成查询系统异常的困难。先看一段程序，看看会发生什么。

// 工作线程，执行除法操作 public class DivTask implements Runnable { private int number, division; public DivTask(int number, int division) { this.number = number; this.division = division; } public void run() { System.out.println(number/division); } } public class ThreadPoolEatException { public static void main(String[] args) { ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 10, 0, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); for(int i=0; i<3; i++) { // 无法打印堆栈信息 threadPool.submit(new DivTask(99, i)); } } } 运行结果：

99

49

从程序中很明显看出，应该是会打印三条信息，但结果却是只有二条，很明显除数为0的结果没有打印出来。仔细看submit() 方法，会发现有返回值。再看下面的代码。

public class ThreadPoolEatException { public static void main(String[] args) { ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 10, 0, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); for(int i=0; i<3; i++) { // 无法打印堆栈信息 Future future = threadPool.submit(new DivTask(99, i)); try { future.get(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ExecutionException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }

看ThreadPoolExecutor的源码发现，该类提供了execute()方法。

public class ThreadPoolEatException { public static void main(String[] args) { ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 10, 0, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()); for(int i=0; i<3; i++) { // 可以打印出堆栈信息 threadPool.execute(new DivTask(99, i)); } } }

可以看到该堆栈信息和前面的比起来少了很多，少的主要是缺少线程池执行的地方。看一下线程池的类关系图。

ExecutorService和Executor是接口，构成父子关系，Executor是顶层接口，只有一个方法，ExecutorService继承了Executor接口，新增了很多额外的方法。抽象类AbstractExecutorService实现了ExecutorService接口，必然实现了submit方法，而ThreadPoolExecutor继承了AbstractExecutorService，除了能调用submit方法外还额外提供了execute方法，execute方法没有把异常吃掉，发生异常会直接抛出来。Executors和其他的类和接口都没有关系，个人认为其仅仅是一个工具类，包装了若干个初始化线程池的方法，这样方法都只需要传入线程数量等参数，不需要像ThreadPoolExecutor一样初始化时需要提供很多参数，进一步简化了开发者的门槛。