異步執(zhí)行對(duì)于開發(fā)者來說并不陌生，在實(shí)際的開發(fā)過程中，很多場(chǎng)景多會(huì)使用到異步，相比同步執(zhí)行，異步可以大大縮短請(qǐng)求鏈路耗時(shí)時(shí)間，比如：發(fā)送短信、郵件。
異步的八種實(shí)現(xiàn)方式：
- 線程異步
Thread/Runnable -
Future+Callable - 異步框架
CompletableFuture - Spring 注解
@Async -
Spring ApplicationEvent事件 - 第三方異步框架，比如 Hutool 的
ThreadUtil -
Guava異步 - 消息隊(duì)列
1、線程異步
public class ThreadTest implements Runnable{
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
public static void main(String[] args) {
ThreadTest threadTest = new ThreadTest();
new Thread(threadTest).start();
}
}
當(dāng)然，如果每次都創(chuàng)建一個(gè) Thread 線程，頻繁的創(chuàng)建、銷毀，浪費(fèi)系統(tǒng)資源，我們可以采用線程池：【Thread】線程池的 7 種創(chuàng)建方式及自定義線程池
2、Future 異步
public class FutureTest {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<String> future = executor.submit(() -> {
Thread.sleep(2000);
return "this is future execute final result!!!";
});
//這里需要返回值時(shí)會(huì)阻塞主線程
String result = future.get();
System.out.println(result);
executor.shutdown();
}
}
Future的不足之處的包括以下幾點(diǎn)：
- 無法被動(dòng)接收異步任務(wù)的計(jì)算結(jié)果：雖然我們可以主動(dòng)將異步任務(wù)提交給線程池中的線程來執(zhí)行，但是待異步任務(wù)執(zhí)行結(jié)束之后，主線程無法得到任務(wù)完成與否的通知，它需要通過get方法主動(dòng)獲取任務(wù)執(zhí)行的結(jié)果。
- Future件彼此孤立：有時(shí)某一個(gè)耗時(shí)很長(zhǎng)的異步任務(wù)執(zhí)行結(jié)束之后，你想利用它返回的結(jié)果再做進(jìn)一步的運(yùn)算，該運(yùn)算也會(huì)是一個(gè)異步任務(wù)，兩者之間的關(guān)系需要程序開發(fā)人員手動(dòng)進(jìn)行綁定賦予，F(xiàn)uture并不能將其形成一個(gè)任務(wù)流（pipeline），每一個(gè)Future都是彼此之間都是孤立的，所以才有了后面的CompletableFuture，CompletableFuture就可以將多個(gè)Future串聯(lián)起來形成任務(wù)流。
- Futrue沒有很好的錯(cuò)誤處理機(jī)制：截止目前，如果某個(gè)異步任務(wù)在執(zhí)行發(fā)的過程中發(fā)生了異常，調(diào)用者無法被動(dòng)感知，必須通過捕獲get方法的異常才知曉異步任務(wù)執(zhí)行是否出現(xiàn)了錯(cuò)誤，從而在做進(jìn)一步的判斷處理
3、CompletableFuture
關(guān)于 CompletableFuture 更多詳情請(qǐng)看：【異步】Futurn、FutureTask、CompletionService、CompletableFuture
public static void thenRunAsync() throws ExecutionException, InterruptedException {
CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(() -> {
System.out.println(Thread.currentThread() + " cf1 do something....");
return 1;
});
CompletableFuture<Void> cf2 = cf1.thenRunAsync(() -> {
System.out.println(Thread.currentThread() + " cf2 do something...");
});
//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->" + cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->" + cf2.get());
}
4、Spring 注解 @Async
@Configuration
public class ThreadPoolConfig {
@Bean("taskExecutor")
public Executor taskExecutor() {
//返回可用處理器的Java虛擬機(jī)的數(shù)量 12
int i = Runtime.getRuntime().availableProcessors();
System.out.println("系統(tǒng)最大線程數(shù) ： " + i);
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//核心線程池大小
executor.setCorePoolSize(16);
//最大線程數(shù)
executor.setMaxPoolSize(20);
//配置隊(duì)列容量，默認(rèn)值為Integer.MAX_VALUE
executor.setQueueCapacity(99999);
//活躍時(shí)間
executor.setKeepAliveSeconds(60);
//線程名字前綴
executor.setThreadNamePrefix("asyncServiceExecutor -");
//設(shè)置此執(zhí)行程序應(yīng)該在關(guān)閉時(shí)阻止的最大秒數(shù)，以便在容器的其余部分繼續(xù)關(guān)閉之前等待剩余的任務(wù)完成他們的執(zhí)行
executor.setAwaitTerminationSeconds(60);
//等待所有的任務(wù)結(jié)束后再關(guān)閉線程池
executor.setWaitForTasksToCompleteOnShutdown(true);
return executor;
}
}
@Service
@EnableAsync
public class AsyncServiceImpl implements AsyncService {
@Override
@Async("taskExecutor")
public String sendSms() {
System.out.println(Thread.currentThread().getName());
return null;
}
@Override
@Async("taskExecutor")
public String sendEmail() {
System.out.println(Thread.currentThread().getName());
return null;
}
}
在實(shí)際項(xiàng)目中， 使用 @Async 調(diào)用線程池，推薦等方式是是使用自定義線程池的模式，不推薦直接使用 @Async 直接實(shí)現(xiàn)異步
5、Spring ApplicationEvent 事件
Spring 中使用事件只需要以下的幾個(gè)步驟：
- 定義事件，繼承
ApplicationEvent - 定義監(jiān)聽，要么實(shí)現(xiàn)
ApplicationListener接口，要么在方法上添加@EventListener注解 - 定義發(fā)布事件接口，調(diào)用
ApplicationContext.publishEvent()或者ApplicationEventPublisher.publishEvent(); - 業(yè)務(wù)調(diào)用發(fā)布事件
@Getter
@Setter
public class BaseEvent<T> extends ApplicationEvent {
private T data;
public BaseEvent(Object source) {
super(source);
}
public BaseEvent(Object source, T data) {
super(source);
this.data = data;
}
}
@Component
public class BaseEventListener implements ApplicationListener<BaseEvent<UserVo>> {
@Override
@Async("taskExecutor")
public void onApplicationEvent(BaseEvent<UserVo> baseEvent) {
UserVo eventData = baseEvent.getData();
// TODO 業(yè)務(wù)處理
}
}
@Autowired
private ApplicationContext applicationContext;
@GetMapping("/pubEvent")
public void pubEvent() {
BaseEvent<UserVo> baseEvent = new BaseEvent<>("event", new UserVo());
applicationContext.publishEvent(baseEvent);
}
6、Hutool 的 ThreadUtil
public static void main(String[] args) {
for (int i = 0; i < 3; i++) {
ThreadUtil.execAsync(() -> {
ThreadLocalRandom threadLocalRandom = ThreadLocalRandom.current();
int number = threadLocalRandom.nextInt(20) + 1;
System.out.println(number);
});
log.info("當(dāng)前第：" + i + "個(gè)線程");
}
log.info("task finish!");
}
7、 Guava 異步
public static void test() {
ListeningExecutorService executorService = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool());
final ListenableFuture<Integer> listenableFuture = executorService.submit(() -> {
log.info("callable execute...");
TimeUnit.SECONDS.sleep(1);
return 1;
});
Futures.addCallback(listenableFuture, new FutureCallback<Integer>() {
@Override
public void onSuccess(@Nullable Integer integer) {
System.out.println("Get listenable future's result with callback " + integer);
}
@Override
public void onFailure(Throwable throwable) {
throwable.printStackTrace();
}
}, Executors.newCachedThreadPool());
}
8、 消息隊(duì)列文章來源：http://www.zghlxwxcb.cn/news/detail-692576.html
常用的消息隊(duì)列：RabbitMq、RocketMq文章來源地址http://www.zghlxwxcb.cn/news/detail-692576.html
到了這里，關(guān)于【異步】Java 的 8 種異步實(shí)現(xiàn)方式的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
