# 二、Java開啟非同步的兩種方式 ## 1、註解開啟：==@Async== ### 1.1、配置非同步的線程池 - 必須配置非同步線程池，否則非同步不會生效。 - @EnableAsync 註解：指定非同步線程池。不指定預設使用：SimpleAsyncTaskExecutor線程池 - SimpleAsy ...
二、Java開啟非同步的兩種方式
1、註解開啟：@Async
1.1、配置非同步的線程池
- 必須配置非同步線程池，否則非同步不會生效。
- @EnableAsync 註解：指定非同步線程池。不指定預設使用：SimpleAsyncTaskExecutor線程池
- SimpleAsyncTaskExecutor是一個最簡單的線程池，它沒有任何的線程相關參數配置，它會為每個任務創建一個新的線程來執行，因此不建議在生產環境中使用。
- 配置線程池見：https://www.cnblogs.com/kakarotto-chen/p/17428432.html
package com.cc.md.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.ThreadPoolExecutor;
/** IO型的線程池
* @author CC
* @since 2023/5/23 0023
*/
@Configuration
@EnableAsync
public class IoThreadPool {
public static final int THREAD_SIZE = 2 * (Runtime.getRuntime().availableProcessors());
public static final int QUEUE_SIZE = 1000;
@Bean(name = "myIoThreadPool")
public ThreadPoolTaskExecutor threadPoolExecutor(){
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(THREAD_SIZE);
executor.setMaxPoolSize(THREAD_SIZE);
executor.setQueueCapacity(QUEUE_SIZE);
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
executor.setKeepAliveSeconds(60);
executor.setAllowCoreThreadTimeOut(true);
executor.setAwaitTerminationSeconds(300);
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.setThreadNamePrefix("myIo-Th-Pool-");
executor.initialize();
return executor;
}
}
1.2、非同步方法
- 非同步方法必須寫在另一個類中，否則不生效
- @Async可以打在類上、也可以打在方法上
1 @Async：類上，說明整個類中的方法都是非同步。必須寫我們自己配置的線程池 —— ("myIoThreadPool")
2 @Async：方法上，說明這個方法是非同步。不用寫我們自己配置的線程池
- 非同步介面+實現類
介面
package com.cc.md.service;
/**
* @author CC
* @since 2023/5/24 0024
*/
public interface IAsyncService {
/** 非同步方法1
* @since 2023/5/24 0024
* @author CC
**/
void async1();
/** 非同步方法2
* @since 2023/5/24 0024
* @author CC
**/
void async2();
}
實現類
package com.cc.md.service.impl;
import com.cc.md.service.IAsyncService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
/** 1 @Async：類上，說明整個類中的方法都是非同步。必須寫我們自己配置的線程池 —— ("myIoThreadPool")
* 2 @Async：方法上，說明這個方法是非同步。不用寫我們自己配置的線程池
* @author CC
* @since 2023/5/24 0024
*/
@Service
@Async("myIoThreadPool")
public class AsyncServiceImpl implements IAsyncService {
private static final Logger log = LoggerFactory.getLogger(AsyncServiceImpl.class);
//類上寫了@Async，這裡就可以不寫了。
//可以不寫 ("myIoThreadPool")。因為在IoThreadPool中開啟了非同步，說明非同步用的就是我們配置的io線程池
//如果類上面打了 @Async ，這裡必須寫：("myIoThreadPool")
@Override
//@Async
public void async1(){
//模仿io流耗時
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info("列印：{}", "非同步方法1111！");
}
//@Async在類上面，說明這個方法也是非同步方法。如果不打，無法開啟非同步。
@Override
public void async2(){
//模仿io流耗時
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info("列印：{}", "非同步方法2222！");
}
}
1.3、測試
@Resource
private IAsyncService asyncService;
//開啟非同步1 —— @Async
@Test
public void test03() throws Exception {
log.info("列印：{}", "非同步測試的-主方法1");
asyncService.async1();
asyncService.async2();
//不會等待非同步方法執行，直接返回前端數據
log.info("列印：{}", "非同步測試的-主方法2");
}
結果：
2、CompletableFuture的方式
使用：
@Resource(name = "myIoThreadPool")
private ThreadPoolTaskExecutor myIoThreadPool;
//開啟非同步2 —— CompletableFuture.runAsync()
@Test
public void test04() throws Exception {
log.info("列印：{}", "非同步測試的-主方法1");
CompletableFuture.runAsync(() -> {
log.info("列印：{}", "非同步方法1！");
//非同步執行的代碼，也可以是方法，該方法不用單獨寫到其他類中。
this.async2("非同步方法1！-end");
}, myIoThreadPool);
//不會等待非同步方法執行，直接返回前端數據
log.info("列印：{}", "非同步測試的-主方法2");
}
//非同步需要執行的方法，可以寫在同一個類中。
private void async2(String msg) {
//模仿io流耗時
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info("列印：{}", msg);
}
結果：
- 後續CompletableFuture的使用見：《Java的CompletableFuture，Java的多線程開發》
