专栏首页后端Coderjava之异步线程Executor

java之异步线程Executor

java单体应用服务使用异步线程去做业务还是蛮常见的,对于微服务应用使用异步线程跑业务逻辑也可以,看自己如何使用了。

说起异步,下意识就想到同步,这两个概念每个人都有着不同的理解,在这我们只是提下这关键词,具体的理解,可自行斟酌。

在用户操作你的系统时什么最重要,当然是可用性排在最前面咯,其次在我看来就是页面的响应时间了,这里有的人或许会知道RT这个缩写,作为一个普通用户在操作你的系统时,如果点击一下菜单老半天没有反应,估计反手就是一个关闭按钮,心里.............什么玩意,坏笑。

为了使系统仅可能的看起来高大上,给使用者最直观的效果,人们总是想尽着各种方法进行优化自己的系统,负载均衡,分布式,最近站点访问,异步等各种技术就会轮番上场就是为了争取用户流量本身,拉近与用户之间的距离。

好了,下面我们说下如何在java中如何异步线程池去写一个示例程序吧。

package com.wpw.asyncthreadpool;

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

import java.util.concurrent.*;

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    private ThreadPoolExecutor threadPoolExecutor;

    @Override
    public Executor getAsyncExecutor() {
        /**这里我们自己手写一个自定义线程池*/
        threadPoolExecutor = new ThreadPoolExecutor(
                Runtime.getRuntime().availableProcessors(),
                Runtime.getRuntime().availableProcessors() << 1,
                60,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(1000),
                new ThreadPoolExecutor.AbortPolicy()
        );

        return threadPoolExecutor;
    }
}

上面的代码是基于Springboot提供的注解@EnableAsync去实现异步的作用,我只是实现了AsyncConfigurer在其提供的方法里面实现了自己的线程池,配置上自己需要设置的参数,其实这些参数的设置针对不同场景下略显不一样,自己看场景吧。

ok,现在我们开始继续编码模拟异步的效果了,我们还是一贯的风格进行看代码示例程序了。

首先我们先定义一个接口

/**
 * @author 公众号~后端Coder
 */
public  interface AsyncService {
    /**
     * 执行异步业务的方法
     */
    void async();
}

然后定义一个实现类,实现上面的接口

package com.wpw.asyncthreadpool;

import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

/**
 * 实现提供异步方法的接口进行自己业务逻辑的书写
 * 这里仅是模拟一下业务逻辑的耗时,具体还是针对自己的业务来说吧
 *
 * @author pc
 */
@Service
@Data
@Slf4j
public class AsyncServiceImpl implements AsyncService {
    @Async
    @Override
    public void async() {
        log.info("开始进行业务逻辑执行");
        try {
            TimeUnit.SECONDS.sleep(20);
        } catch (InterruptedException e) {
            log.error("线程中断异常:{}", e);
        }
        log.info("业务逻辑执行结束");
    }
}

注意两点,其一在实现类上面加上@Service,这样Spring 就会将这个类进行实例化。其二是在进行异步业务方法上面加上@Async注解,用于表示这是异步方法。在代码里面我们输出了日志信息,后面说明日志信息的作用。

好了,为了更加直观的去看异步的效果,我们再看一段示例程序。

package com.wpw.asyncthreadpool;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author 公众号~后端Coder
 */
@RestController
public class UserController {
    private final AsyncService asyncService;

    public UserController(AsyncService asyncService) {
        this.asyncService = asyncService;
    }

    @GetMapping(value = "/hello")
    public String hello() {
        asyncService.async();
        return "hello";
    }
}

我们定义一个Controller类,通过启动程序,启动这个项目。

我们在浏览器上输入http://localhost:8080/hello即可看到hello显示在浏览器上面,然后项目日志输出

log.info("开始进行业务逻辑执行");

由于我在程序中为了更加模拟业务逻辑的耗时,模拟了20秒,接下来我们看下后台打印日志信息的两者之间的时间差是不是20秒左右。

2019-10-25 20:41:48.132  INFO 11808 --- [pool-1-thread-2] c.wpw.asyncthreadpool.AsyncServiceImpl   : 开始进行业务逻辑执行
2019-10-25 20:42:08.049  INFO 11808 --- [pool-1-thread-1] c.wpw.asyncthreadpool.AsyncServiceImpl   : 业务逻辑执行结束

由于日志太多我们仅看我们需要的日志信息就好了。我们访问controller接口是立即返回的信息,但是业务还是在继续执行,这就是我们想要达到的异步效果,其实异步不仅仅可以这样做,有很多方法可以去做,今天我们就暂时先介绍这一种

本文分享自微信公众号 - 后端Coder(gh_245290c1861a)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-10-27

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Java Getter/Setter “防坑指南”

    Getter/Setter 在 Java 中被广泛使用,看似简单,但并非每个 Java 开发人员都能很好理解并正确实现 Getter/Setter 方法。因此,...

    乔戈里
  • Spring-data-redis 的实现原理

    强烈建议阅读Spring-session原理的"2.spring-session重写servlet request 及 redis实现存储相关问题"

    平凡的学生族
  • 2019 Java 开发者跳槽指南.pdf (吐血整理)

    最近发现一些公众号的读者,留言提到跳槽面试的事情。当中,有几个编程老兵,说他们从事 Java 开发多年,薪资却还在原地打转,跳槽升职不是很顺利,十分困惑。这显然...

    老钱
  • 聊聊NacosNamingService的subscribe及unsubscribe

    本文主要研究一下NacosNamingService的subscribe及unsubscribe

    codecraft
  • 所谓代码生成,简单!我详细分析给你看!

    现在很多开源的脚手架项目一般都会有自己的代码生成器,能够帮助快速生成代码,一般都是根据表结构生成实体,和实体对应的操作类,比如controller、servic...

    java思维导图
  • 深入 C++ 回调

    ? 许多面试官会问:你知道回调吗?你在写回调的时候遇到哪些坑?你知道对象生命周期管理吗?为什么这里会崩溃,那里会泄漏? 在设计 C++ 回调时,你是否想过:同...

    腾讯技术工程官方号
  • 2019 Java 开发者跳槽指南.pdf(吐血整理)

    最近发现一些公众号的读者,留言提到跳槽面试的事情。当中,有几个编程老兵,说他们从事Java开发多年,薪资却还在原地打转,跳槽升职不是很顺利,十分困惑。这显然是遇...

    Java3y
  • JVM优化系列-------[2丶查看jvm的运行参数]

    运行java命令打印参数,只需要添加-XX:+PrintFlagsFinal参数即可

    框架师
  • JVM优化系列-------[1丶jvm的三种运行参数]

    在本地开发环境中我们很少会遇到需要对jvm进行优化的需求,但是到了生产环境,我们可能将有下面的需求:

    框架师
  • Java集合详解3:一文读懂Iterator,fail-fast机制与比较器

    《Java集合详解系列》是我在完成夯实Java基础篇的系列博客后准备开始写的新系列。

    Java技术江湖

扫码关注云+社区

领取腾讯云代金券