做网站简介,网站通常用什么编程做,域名 网站名称,网站域名注册费用在《深入源码分析Java线程池的实现原理》这篇文章中#xff0c;我们介绍过了Java中线程池的常见用法以及基本原理。 在文中有这样一段描述#xff1a; 可以通过Executors静态工厂构建线程池#xff0c;但一般不建议这样使用。 关于这个问题#xff0c;在那篇文章中并没有深…在《深入源码分析Java线程池的实现原理》这篇文章中我们介绍过了Java中线程池的常见用法以及基本原理。 在文中有这样一段描述 可以通过Executors静态工厂构建线程池但一般不建议这样使用。 关于这个问题在那篇文章中并没有深入的展开。作者之所以这么说是因为这种创建线程池的方式有很大的隐患稍有不慎就有可能导致线上故障如一次Java线程池误用引发的血案和总结 https://zhuanlan.zhihu.com/p/32867181 本文我们就来围绕这个问题来分析一下为什么JDK自身提供的构建线程池的方式并不建议使用到底应该如何创建一个线程池呢 Executors Executors 是一个Java中的工具类。提供工厂方法来创建不同类型的线程池。 从上图中也可以看出Executors的创建线程池的方法创建出来的线程池都实现了ExecutorService接口。常用方法有以下几个 newFiexedThreadPool(int Threads)创建固定数目线程的线程池。 newCachedThreadPool()创建一个可缓存的线程池调用execute 将重用以前构造的线程如果线程可用。如果没有可用的线程则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。 newSingleThreadExecutor()创建一个单线程化的Executor。 newScheduledThreadPool(int corePoolSize)创建一个支持定时及周期性的任务执行的线程池多数情况下可用来替代Timer类。 类看起来功能还是比较强大的又用到了工厂模式、又有比较强的扩展性重要的是用起来还比较方便如 ExecutorService executor Executors.newFixedThreadPool(nThreads) ; 即可创建一个固定大小的线程池。 但是为什么我说不建议大家使用这个类来创建线程池呢 我提到的是『不建议』但是在阿里巴巴Java开发手册中也明确指出而且用的词是『不允许』使用Executors创建线程池。 Executors存在什么问题 在阿里巴巴Java开发手册中提到使用Executors创建线程池可能会导致OOM(OutOfMemory ,内存溢出)但是并没有说明为什么那么接下来我们就来看一下到底为什么不允许使用Executors 我们先来一个简单的例子模拟一下使用Executors导致OOM的情况。 /*** author Hollis*/
public class ExecutorsDemo { private static ExecutorService executor Executors.newFixedThreadPool(15); public static void main(String[] args) { for (int i 0; i Integer.MAX_VALUE; i) { executor.execute(new SubThread()); } } } class SubThread implements Runnable { Override public void run() { try { Thread.sleep(10000); } catch (InterruptedException e) { //do nothing } } } 通过指定JVM参数-Xmx8m -Xms8m 运行以上代码会抛出OOM: Exception in thread main java.lang.OutOfMemoryError: GC overhead limit exceeded at java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:416) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1371) at com.hollis.ExecutorsDemo.main(ExecutorsDemo.java:16) 以上代码指出ExecutorsDemo.java的第16行就是代码中的executor.execute(new SubThread());。 Executors为什么存在缺陷 通过上面的例子我们知道了Executors创建的线程池存在OOM的风险那么到底是什么原因导致的呢我们需要深入Executors的源码来分析一下。 其实在上面的报错信息中我们是可以看出蛛丝马迹的在以上的代码中其实已经说了真正的导致OOM的其实是LinkedBlockingQueue.offer方法。 Exception in thread main java.lang.OutOfMemoryError: GC overhead limit exceeded at java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:416) at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1371) at com.hollis.ExecutorsDemo.main(ExecutorsDemo.java:16) 如果读者翻看代码的话也可以发现其实底层确实是通过LinkedBlockingQueue实现的 public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueueRunnable()); 如果读者对Java中的阻塞队列有所了解的话看到这里或许就能够明白原因了。 Java中的BlockingQueue主要有两种实现分别是ArrayBlockingQueue 和 LinkedBlockingQueue。 ArrayBlockingQueue是一个用数组实现的有界阻塞队列必须设置容量。 LinkedBlockingQueue是一个用链表实现的有界阻塞队列容量可以选择进行设置不设置的话将是一个无边界的阻塞队列最大长度为Integer.MAX_VALUE。 这里的问题就出在不设置的话将是一个无边界的阻塞队列最大长度为Integer.MAX_VALUE。也就是说如果我们不设置LinkedBlockingQueue的容量的话其默认容量将会是Integer.MAX_VALUE。 而newFixedThreadPool中创建LinkedBlockingQueue时并未指定容量。此时LinkedBlockingQueue就是一个无边界队列对于一个无边界队列来说是可以不断的向队列中加入任务的这种情况下就有可能因为任务过多而导致内存溢出问题。 上面提到的问题主要体现在newFixedThreadPool和newSingleThreadExecutor两个工厂方法上并不是说newCachedThreadPool和newScheduledThreadPool这两个方法就安全了这两种方式创建的最大线程数可能是Integer.MAX_VALUE而创建这么多线程必然就有可能导致OOM。 创建线程池的正确姿势 避免使用Executors创建线程池主要是避免使用其中的默认实现那么我们可以自己直接调用ThreadPoolExecutor的构造函数来自己创建线程池。在创建的同时给BlockQueue指定容量就可以了。 private static ExecutorService executor new ThreadPoolExecutor(10, 10, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue(10)); 这种情况下一旦提交的线程数超过当前可用线程数时就会抛出java.util.concurrent.RejectedExecutionException这是因为当前线程池使用的队列是有边界队列队列已经满了便无法继续处理新的请求。但是异常Exception总比发生错误Error要好。 除了自己定义ThreadPoolExecutor外。还有其他方法。这个时候第一时间就应该想到开源类库如apache和guava等。 作者推荐使用guava提供的ThreadFactoryBuilder来创建线程池。 public class ExecutorsDemo { private static ThreadFactory namedThreadFactory new ThreadFactoryBuilder() .setNameFormat(demo-pool-%d).build(); private static ExecutorService pool new ThreadPoolExecutor(5, 200, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueueRunnable(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); public static void main(String[] args) { for (int i 0; i Integer.MAX_VALUE; i) { pool.execute(new SubThread()); } } } 通过上述方式创建线程时不仅可以避免OOM的问题还可以自定义线程名称更加方便的出错的时候溯源。 思考题文中作者说发生异常Exception要比发生错误Error好为什么这么说 文中提到的《阿里巴巴Java开发手册》请关注公众号Hollis回复手册。即可获得完整版PDF。 from: https://www.hollischuang.com/archives/2888转载于:https://www.cnblogs.com/GarfieldEr007/p/9954877.html
