反对使用Spring封装的多线程类原因

目录
  • 1.Spring的异步代码
  • 2.是SpringBoot救了你
  • 3.End

前言：

工作总难免会遇到被故障所驱使，其实是开启了线程池的暴力使用模式

我有必要简单的复述一下。其主要原因，就是开发人员，在每一次方法调用里，都创建了一个单独的线程池去处理。这样的话，如果请求量一增加，整个操作系统的压力就会耗尽，最终所有的业务都无法响应。

我一直认为这是一个非常偶发的低级错误，发生频率非常的低。但随着这样的故障越来越多，xjjdog认识到这是一个普遍的现象。

以异步性能优化为目的，反而带来的整体业务不可用的结果，是非常打脸的一种优化。

1.Spring的异步代码

Spring作为Java届的杠把子框架，其过度封装的API深得开发人员的喜爱。根据语义化编程的逻辑，只要某些关键字在语言层面上过得去，我们就可以把它给加上去。比如@Async注解。

我永远想不通是什么给了开发人员勇气，去加上这个@Async注解，因为这种涉及到多线程的东西，即使是自己去创建线程，也是心怀敬畏，唯恐扰了操作系统的安宁。@Async这样的黑盒，真的可以那么顺畅的使用么？

我们不妨debug一下代码，让子弹飞一会儿。

首先，生成一个小小的项目，然后在主类上加上必须的注解。嗯，别忘了这一环，否则你后面加的注解将没什么用处。

@SpringBootApplication
@EnableAsync
public class DemoApplication {

创造一个带@Async注解的方法。

@Component
public class AsyncService {
    @Async
    public void async(){
        try {
            Thread.sleep(1000);
            System.out.println(Thread.currentThread());
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

然后，做一个对应的test接口，访问时会调用这个async方法。

@ResponseBody
@GetMapping("test")
public void test(){
    service.async();
}

访问时，直接打个断点，即可获取执行异步线程的线程池。

可以看到，异步任务使用了一个线程池，它的corePoolSize=8, 阻塞队列采用了无界队列LinkedBlockingQueue。一旦采用了这样的组合，最大线程数就会形同虚设，因为超出8个线程的任务，将全部会被放到无界队列里。使得下面的代码变成了摆设。

throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, var4);

如果你的访问量非常大，这些任务将全部堆积在LinkedBlockingQueue里。情况好一点的，这些任务的执行会变得延迟很大；情况坏一点的，任务太多将直接造成内存溢出OOM！

你可能会说，我可以自己指定另外一个ThreadPoolExceute，然后使用@Async注解来声明啊。说这话的同学，一定是能力比较强，或者Review的代码比较少，没有经过猪队友的洗礼。

2.是SpringBoot救了你

SpringBoot是个好东西。

在TaskExecutionAutoConfiguration中，通过生成ThreadPoolTaskExecutor的Bean，来提供默认的Executor。

@ConditionalOnMissingBean({Executor.class})
public ThreadPoolTaskExecutor applicationTaskExecutor(TaskExecutorBuilder builder) {
    return builder.build();
}

也就是我们上面所说的那个。如果没有SpringBoot的助力，Spring将默认使用SimpleAsyncTaskExecutor。

参见org.springframework.aop.interceptor.AsyncExecutionInterceptor。

@Override
@Nullable
protected Executor getDefaultExecutor(@Nullable BeanFactory beanFactory) {
 Executor defaultExecutor = super.getDefaultExecutor(beanFactory);
 return (defaultExecutor != null ? defaultExecutor : new SimpleAsyncTaskExecutor());
}

这就是Spring大仙所干的事。

SimpleAsyncTaskExecutor类设计的非常操蛋，因为它每执行一次，都会创建一个单独的线程，根本没有共用线程池。比如你的TPS是1000，异步执行了任务，那么你每秒将会生成1000个线程！

这明显是想要累死操作系统的节奏。

protected void doExecute(Runnable task) {
 Thread thread = (this.threadFactory != null ? this.threadFactory.newThread(task) : createThread(task));
 thread.start();
}

3.End

明眼人一看，这种使用new线程的处理方式将会是非常可怕的。但就拿Spring本身来说，引用SimpleAsyncTaskExecutor这个类的地方还不少，包括比较流行的AsyncRestTemplate。

这暴露了很多风险，尤其是竟然在这些列表中看到了redis的身影。这个类的设计，使得任务的执行变的非常的不可控。

看这个API，我感觉Spring是进入了设计的魔怔状态。

这个东西的隐藏bug可能还会更深！比如org.springframework.context.event.EventListener注解，用于实现DDD那套所谓的事件驱动模式，有不少框架直接set了AsyncRestTemplate，那么就等死吧。

赶紧把SimpleAsyncTaskExecutor加入你的API黑名单，或者埋坑清单吧！

创建线程有那么难么？需要使用Spring创建的线程？有时候我实在是想不通，暴露出这样的接口目的是为了什么。

就连原生的线程池我们还没搞明白呢，你还给包了一层，这是方便我们甩锅啊！

到此这篇关于反对使用Spring封装的多线程类原因的文章就介绍到这了,更多相关Spring封装多线程类内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • SpringBoot多线程进行异步请求的处理方式

    目录 SpringBoot多线程进行异步请求的处理 第一步:编写配置类 第二步:对方法使用注解标注为使用多线程进行处理 SpringBoot请求线程优化 使用Callable来实现 1.异步调用的另一种方式 3.Deferred方式实现异步调用 SpringBoot多线程进行异步请求的处理 近期在协会博客园中,有人发布了博客,系统进行查重的时候由于机器最低配置进行大量计算时需要十秒左右时间才能处理完,由于一开始是单例模式,导致,在某人查重的时候整个系统是不会再响应别的请求的,导致了系统假死状态,

  • Spring在多线程下@Resource注入为null的问题

    目录 多线程下@Resource注入为null 前情叙述 解决方案 附上其它解决 多线程下@Resource注入为null 前情叙述 记录以下这个坑,我的情况大致是这样的,我在用webmagic写爬虫,在类中通过@Resoource(@Autowired也一样)注入dao接口实例. 然后我在process方法中引用这个实例发现这个实例在这里一直为null,然后我在测试类或者当前类的main函数中引用dao实例就没问题,一切正常(当时 黑人问号脸???) 几经波折,发现原因是spring和多线程安

  • SpringBoot实现动态多线程并发定时任务

    SpringBoot实现动态多线程并发定时任务

    本文实例为大家分享了SpringBoot实现动态多线程并发定时任务的具体代码,供大家参考,具体内容如下 实现定时任务有多种方式,使用spring自带的,继承SchedulingConfigurer的方式. 一.实现 1.启动类 在启动类添加注解@EnableScheduling开启,不然不起用做. 2.新建任务类 添加注解@Component注册到spring的容器中. package com.example.demo.task; import com.example.demo.entity.M

  • 解决springboot 多线程使用MultipartFile读取excel文件内容报错问题

    springboot项目开启多线程 启动类加注解开启 @EnableAsync,实现类方法加注解 @Async 前端页面 报错信息 java.io.FileNotFoundException: C:\Users\dongao\AppData\Local\Temp\tomcat.1255209411477782290.8051\work\Tomcat\localhost\ROOT\upload_7d7b99e5_38da_4a03_93e0_bff20cb48022_00000000.tmp (系

  • 浅谈springboot如何保证多线程安全

    浅谈springboot如何保证多线程安全

    目录 如何保证多线程安全 1.springboot在多线程并发访问下是怎么做的 2.controller在多线程下如何尽可能保证线程安全,如何取舍 3.小结一下 单例模式与线程安全问题踩的坑 下面上一张该类的截图 现在说下解决方法 如何保证多线程安全 1.springboot在多线程并发访问下是怎么做的 我们在Controller下,一般都是@AutoWired一些Service,由于这些Service都交给了spring进行管理,因此他们单例的,对于在Controller中调用他们的方法,由于

  • Springboot实现多线程注入bean的工具类操作

    场景: 使用springboot多线程,线程类无法自动注入需要的bean 解决方法: 通过工具类获取需要的bean 工具类代码: import org.springframework.beans.BeansException; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springfram

  • spring scheduled单线程和多线程使用过程中的大坑

    公司在使用定时任务的时候,使用的是spring scheduled. 代码如下: @EnableScheduling public class TaskFileScheduleService {     @Scheduled(cron="0 */1 * * * ?")     public void task1(){     .......     }          @Scheduled(cron="0 */1 * * * ?")     public void

  • 反对使用Spring封装的多线程类原因

    反对使用Spring封装的多线程类原因

    目录 1.Spring的异步代码 2.是SpringBoot救了你 3.End 前言: 工作总难免会遇到被故障所驱使,其实是开启了线程池的暴力使用模式 我有必要简单的复述一下.其主要原因,就是开发人员,在每一次方法调用里,都创建了一个单独的线程池去处理.这样的话,如果请求量一增加,整个操作系统的压力就会耗尽,最终所有的业务都无法响应. 我一直认为这是一个非常偶发的低级错误,发生频率非常的低.但随着这样的故障越来越多,xjjdog认识到这是一个普遍的现象. 以异步性能优化为目的,反而带来的整体业务

  • Spring boot使用多线程过程步骤解析

    Spring中实现多线程,其实非常简单,只需要在配置类中添加@EnableAsync就可以使用多线程.在希望执行的并发方法中使用@Async就可以定义一个线程任务.通过spring给我们提供的ThreadPoolTaskExecutor就可以使用线程池. 第一步,先在Spring Boot主类中定义一个线程池,比如: package com.jmxf.core.config; import java.util.concurrent.Executor; import org.springframe

  • 详解spring封装hbase的代码实现

    前面我们讲了spring封装MongoDB的代码实现,这里我们讲一下spring封装Hbase的代码实现. hbase的简介: 此处大概说一下,不是我们要讨论的重点. HBase是一个分布式的.面向列的开源数据库,HBase在Hadoop之上提供了类似于Bigtable的能力.HBase是Apache的Hadoop项目的子项目.HBase不同于一般的关系数据库,它是一个适合于非结构化数据存储的数据库.另一个不同的是HBase基于列的而不是基于行的模式.hbase是bigtable的开源山寨版本.

  • Spring MVC 注解自动扫描失效原因分析

    关于spring自动扫描,在控制层,采用注解配置@Controller,项目能够成功启动,且无任何报错.但是 在进行页面跳转时,并未进行相应的拦截,整个界面只能在默认界面 ,跳转报404,由于楼主初次尝试,在绕了一个大圈后,初步确认是在扫描时mvc控制器,并未成功,详情请看代码 <!-- 开启controller注解支持 --> <context:component-scan base-package="com.cjw.test.controller" use-def

  • spring boot中多线程开发的注意事项总结

    前言 Springt通过任务执行器(TaskExecutor)来实现多线程和并发编程.使用ThreadPoolTaskExecutor可实现一个基于线程池的TaskExecutor.而实际开发中任务一般是非阻碍的,即异步的,所以我们要在配置类中通过@EnableAsync 开启对异步任务的支持,并通过实际执行Bean的方法中使用@Async注解来声明其是一个异步任务. 基于springboot的多线程程序开发过程中,由于本身也需要注入spring容器进行管理,才能发挥springboot的优势.

  • 通过实例了解java spring使用构造器注入的原因

    这篇文章主要介绍了通过实例了解spring使用构造器注入的原因,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.前言 Spring框架对Java开发的重要性不言而喻,其核心特性就是IOC(Inversion of Control, 控制反转)和AOP,平时使用最多的就是其中的IOC,我们通过将组件交由Spring的IOC容器管理,将对象的依赖关系由Spring控制,避免硬编码所造成的过度程序耦合. 二.常见的三种注入方式 2.1 field注

  • Spring Boot定时+多线程执行过程解析

    Spring Boot定时+多线程执行过程解析

    这篇文章主要介绍了Spring Boot定时+多线程执行过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 Spring Boot 定时任务有多种实现方式,我在一个微型项目中通过注解方式执行定时任务. 具体执行的任务,通过多线程方式执行,单线程执行需要1小时的任务,多线程下5分钟就完成了. 执行效率提升10倍以上,执行效率提升10倍以上,执行效率提升10倍以上. 重要的事情说三遍! 本文不深入介绍具体的原理,大家如果要实现类似的功能,只需要

  • 详解Spring中BeanUtils工具类的使用

    目录 简介 Spring的BeanUtils方法 Spring的BeanUtils与Apache的BeanUtils区别 实例 简介 说明 本文介绍Spring的BeanUtils工具类的用法. 我们经常需要将不同的两个对象实例进行属性复制,比如将DO对象进行属性复制到DTO,这种转换最原始的方式就是手动编写大量的 get/set代码,很繁琐.为了解决这一痛点,就诞生了一些方便的类库,常用的有 Apache的 BeanUtils,Spring的 BeanUtils, Dozer,Orika等拷贝

  • Spring @Transactional事务失效的原因分析

    目录 前言 1.非 public 修饰的方法 2.timeout 超时 3.代码中有 try/catch 4.调用类内部 @Transactional 方法 5.数据库不支持事务 总结 前言 一个程序中不可能没有事务,而 Spring 中,事务的实现方式分为两种:编程式事务和声明式事务,又因为编程式事务实现相对麻烦,而声明式事务实现极其简单,所以在日常项目中,我们都会使用声明式事务 @Transactional 来实现事务. @Transactional 使用极其简单,只需要在类上或方法上添加

  • php封装的smartyBC类完整实例

    本文实例讲述了php封装的smartyBC类.分享给大家供大家参考,具体如下: <?php /** * Project: Smarty: the PHP compiling template engine * File: SmartyBC.class.php * SVN: $Id: $ * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Les

随机推荐