网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

SpringBoot使用Spring的异步线程池的实现

前言

创新互联欢迎来电:18982081108,为您提供成都网站建设网页设计及定制高端网站建设服务,创新互联网页制作领域10年,包括雨棚定制等多个领域拥有丰富的营销推广经验,选择创新互联,为网站保驾护航。

线程池,从名字上来看,就是一个保存线程的"池子",凡事都有其道理,那线程池的好处在哪里呢?

我们要让计算机为我们干一些活,其实都是在使用线程,使用方法就是new一个Runnable接口或者新建一个子类,继承于Thread类,这就会涉及到线程对象的创建与销毁,这两个操作无疑是耗费我们系统处理器资源的,那如何解决这个问题呢? 线程池其实就是为了解决这个问题而生的。

线程池提供了处理系统性能和大用户量请求之间的矛盾的方法,通过对多个任务重用已经存在的线程对象,降低了对线程对象创建和销毁的开销,由于当客户请求到了时,线程对象已经存在,可以提高请求的响应时间从而整体的提高了系统服务的表现。

本篇博客就是要总结一下,如何在Spring中使用异步线程池,给大家一个例子,去体会一下异步这个概念

实习生小王负责后台管理系统的报表分析,他的工作是负责操作后台系统,点击按钮,生成数据报表,而并不需要查看报表,由于数据量大, 生成报表需要花费很长时间,而如果生成报表和其他工作在一个线程,小王就无法干其他工作了,所以需要将生成报表这个任务交给计算机的其他线程,这便是异步的体现。

在Spring中使用异步线程池

spring中提供了AsyncConfigurer这个配置接口,便于我们配置自己的异步线程池。

新建异步配置类

我习惯新建一个config包,然后将一些组件的配置类都放到里面

Spring Boot使用Spring的异步线程池的实现

package com.example.wyh.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**
 * @author 阳光大男孩!!!
 */
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
  @Override
  public Executor getAsyncExecutor() {
    //定义线程池
    ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
    //设置核心线程数
    threadPoolTaskExecutor.setCorePoolSize(10);
    //设置线程池最大线程数
    threadPoolTaskExecutor.setMaxPoolSize(30);
    //设置线程队列最大线程数
    threadPoolTaskExecutor.setQueueCapacity(2000);
    //初始化线程池
    threadPoolTaskExecutor.initialize();

    return threadPoolTaskExecutor;
  }
}

在上面代码中,我们使用@Configuration告诉spring这是一个配置类,使用注解@EnableAsync让spring开启异步可用。 这样以后如果想把某个方法中的任务异步地放到另外一个线程,只需要通过方法上加 @Async注解即可。

新建一个服务接口,并实现

package com.example.wyh.Service;

/**
 * @author 阳光大男孩!!!
 */
public interface AsyncService {

  /**
   * 测试使用异步线程池来执行工作
   */
  public void useAsyncThreadWork();
  
}
package com.example.wyh.Service;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

/**
 * @author 阳光大男孩!!!
 */
@Service
public class AsyncServiceImp implements AsyncService{

  @Override
  @Async
  public void useAsyncThreadWork() {
    System.out.println(Thread.currentThread().getName());

  }
}

在接口的具体实现中,我们打印了当前线程的名称,借以来查看是否是在一个心的线程中执行该任务。并且通过@Service注解告诉spring这是一个Service类型的bean,这样我们就可以让spring通过其自身容器来管理我们的对象,这就是IOC特性的一个体现。

新建一个Controller 进行访问、测试

/**
 * @author 阳光大男孩!!!
 */
@RestController
public class AsyncController {

  @Autowired
  AsyncService asyncService;
  @GetMapping("/testAsync")
  public String testAsync()
  {
    System.out.println(Thread.currentThread().getName());
    asyncService.useAsyncThreadWork();
    return "testAsync方法执行成功...";
  }
}

可以看到,在上述代码中,我们使用 @Autowired注解自动装配了刚才交给Spring容器管理的Service实现类对象,这是spring 的DI特性体现。

由于我开的是8090端口,所以我访问的是8090端口

Spring Boot使用Spring的异步线程池的实现

可以看到打印了两个线程的名称,第一个是在Controller中执行的线程名称,第二个则是spring通过我们刚才的配置,为我们从线程池中提取的线程并为我们执行相应任务。

Spring Boot使用Spring的异步线程池的实现

总结

本篇博客简介了在spring中使用线程池异步执行任务的基本方法,为在项目中使用异步线程池提供了示例。

到此这篇关于Spring Boot使用Spring的异步线程池的实现的文章就介绍到这了,更多相关Spring Boot 异步线程池内容请搜素创新互联以前的文章或下面相关文章,希望大家以后多多支持创新互联!


网页题目:SpringBoot使用Spring的异步线程池的实现
转载源于:http://bjjierui.cn/article/ppeodd.html

其他资讯