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