说起异步,下意识就想到同步,这两个概念每个人都有着不同的理解,在这我们只是提下这关键词,具体的理解,可自行斟酌。
在用户操作你的系统时什么最重要,当然是可用性排在最前面咯,其次在我看来就是页面的响应时间了,这里有的人或许会知道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接口是立即返回的信息,但是业务还是在继续执行,这就是我们想要达到的异步效果,其实异步不仅仅可以这样做,有很多方法可以去做,今天我们就暂时先介绍这一种