多线程的使用,避免ExecutorService 的创建处理

简介: 多线程的使用,避免ExecutorService 的创建处理

前言: 最近在开发的时候,在使用多线程的时候,发现了一些问题,不正确的使用,会产生oom的情况,后面看了阿里巴巴的开发手册,亲自验证了一下问题点 ,解决了问题,特别mark一下 代码: package com.ly.tcgl.sellservice.web.controller;import com.google.common.util.concurrent.ThreadFactoryBuilder;import org.apache.tomcat.util.threads.ThreadPoolExecutor;import java.util.concurrent.*;/**  * @title: 多线程的使用方式,遵守阿里巴巴的规则,否则的话容易产生oom(outofmemory)  * @Author like.ma  * @Date: 2020-09-11 11:16  * @Version 1.0  */publicclassdemo{     //错误的创建线程的方式    privatestatic ExecutorService executorService= Executors.newFixedThreadPool(15);    //正确的创建线程的方式    privatestatic ExecutorService executor =newThreadPoolExecutor(10,10,            60L, TimeUnit.SECONDS,            newArrayBlockingQueue(10));    publicstaticvoidmain(String[] args){        for(int i=0;i<Integer.MAX_VALUE;i++)        {            executor.execute(newSubThread());        }    }



classSubThreadimplementsRunnable{     @Override     publicvoidrun(){        try{            Thread.sleep(100);        }        catch(InterruptedException e){            System.out.println(e);        }    }}

image.gif

第一种方式,

如果读者对Java 中的阻塞队列有所了解的话,看到这里或许就能够明白原  因了。  Java 中的BlockingQueue 主要有两种实现, 分别是ArrayBlockingQueue  和 LinkedBlockingQueue。  ArrayBlockingQueue 是一个用数组实现的有界阻塞队列,必须设置容量。  LinkedBlockingQueue 是一个用链表实现的有界阻塞队列,容量可以选择  进行设置,不设置的话,将是一个无边界的阻塞队列,最大长度为Integer.MAX_  VALUE。  这里的问题就出在:不设置的话,将是一个无边界的阻塞队列,最大长度为  为什么阿里巴巴禁止使用Executors 创建线程池? <  35  Integer.MAX_VALUE。也就是说,如果我们不设置LinkedBlockingQueue 的  容量的话,其默认容量将会是Integer.MAX_VALUE。  而newFixedThreadPool 中创建LinkedBlockingQueue 时,并未指定容  量。此时,LinkedBlockingQueue 就是一个无边界队列,对于一个无边界队列  来说,是可以不断的向队列中加入任务的,这种情况下就有可能因为任务过多而导  致内存溢出问题。  上面提到的问题主要体现在newFixedThreadPool 和newSingleThreadExecutor  两个工厂方法上,并不是说newCachedThreadPool 和newScheduledThreadPool  这两个方法就安全了,这两种方式创建的最大线程数可能是  Integer.MAX_VALUE,而创建这么多线程,必然就有可能导致OOM。

使用过程,会产生oom的情况,进行内存溢出的情况,直接电脑的内存耗尽;

第二种方式,会产生异常,不会产生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 来创建线程池。

异常截图

image.gif编辑

相关文章
|
5月前
|
Java 开发者
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
Java面试题:请解释内存泄漏的原因,并说明如何使用Thread类和ExecutorService实现多线程编程,请解释CountDownLatch和CyclicBarrier在并发编程中的用途和区别
59 0
|
6月前
|
缓存 并行计算 Java
重温JAVA线程池精髓:Executor、ExecutorService及Executors的源码剖析与应用指南
重温JAVA线程池精髓:Executor、ExecutorService及Executors的源码剖析与应用指南
|
5月前
|
设计模式 安全 NoSQL
Java面试题:结合单例模式与Java内存管理,设计一个线程安全的单例类?分析Java多线程工具类ExecutorService与Java并发工具包中的工具类,设计一个Java并发框架的分布式锁实现
Java面试题:结合单例模式与Java内存管理,设计一个线程安全的单例类?分析Java多线程工具类ExecutorService与Java并发工具包中的工具类,设计一个Java并发框架的分布式锁实现
64 0
|
5月前
|
存储 安全 Java
Java面试题:如何在Java应用中实现有效的内存优化?在多线程环境下,如何确保数据的线程安全?如何设计并实现一个基于ExecutorService的任务处理流程?
Java面试题:如何在Java应用中实现有效的内存优化?在多线程环境下,如何确保数据的线程安全?如何设计并实现一个基于ExecutorService的任务处理流程?
47 0
|
7月前
|
Java 调度
Java一分钟之线程池:ExecutorService与Future
【5月更文挑战第12天】Java并发编程中,`ExecutorService`和`Future`是关键组件,简化多线程并提供异步执行能力。`ExecutorService`是线程池接口,用于提交任务到线程池,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。通过`submit()`提交任务并返回`Future`对象,可检查任务状态、获取结果或取消任务。注意处理`ExecutionException`和避免无限等待。实战示例展示了如何异步执行任务并获取结果。理解这些概念对提升并发性能至关重要。
137 5
|
Java
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
ExecutorService、Callable、Future实现有返回结果的多线程原理解析
76 0
|
缓存 Java
Java线程池ExecutorService
Java线程池ExecutorService
107 0
|
存储 安全
使用ExecutorService来停止线程服务
使用ExecutorService来停止线程服务
|
Java
Java多线程之Executor框架:Callable、Future、Executor和ExecutorService
Executor框架是指JDK 1.5中引入的一系列并发库中与Executor相关的功能类,包括Executor、Executors、ExecutorService、Future、Callable等。
1493 0