在SpringBoot怎么優雅的使用多線程

本篇內容主要講解“在SpringBoot怎么優雅的使用多線程”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“在SpringBoot怎么優雅的使用多線程”吧!

快速使用 

SpringBoot應用中需要添加@EnableAsync注解，來開啟異步調用，一般還會配置一個線程池，異步的方法交給特定的線程池完成，如下：

@Configuration
@EnableAsync
public class AsyncConfiguration {
 
    @Bean("doSomethingExecutor")
    public Executor doSomethingExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心線程數：線程池創建時候初始化的線程數
        executor.setCorePoolSize(10);
        // 最大線程數：線程池最大的線程數，只有在緩沖隊列滿了之后才會申請超過核心線程數的線程
        executor.setMaxPoolSize(20);
        // 緩沖隊列：用來緩沖執行任務的隊列
        executor.setQueueCapacity(500);
        // 允許線程的空閑時間60秒：當超過了核心線程之外的線程在空閑時間到達之后會被銷毀
        executor.setKeepAliveSeconds(60);
        // 線程池名的前綴：設置好了之后可以方便我們定位處理任務所在的線程池
        executor.setThreadNamePrefix("do-something-");
        // 緩沖隊列滿了之后的拒絕策略：由調用線程處理（一般是主線程）
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
        executor.initialize();
        return executor;
    }
 
}

使用的方式非常簡單，在需要異步的方法上加@Async注解 

@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @GetMapping("/open/something")
    public String something() {
        int count = 10;
        for (int i = 0; i < count; i++) {
            asyncService.doSomething("index = " + i);
        }
        return "success";
    }
}
 
 
@Slf4j
@Service
public class AsyncService {
 
    // 指定使用beanname為doSomethingExecutor的線程池
    @Async("doSomethingExecutor")
    public String doSomething(String message) {
        log.info("do something, message={}", message);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            log.error("do something error: ", e);
        }
        return message;
    }
}

訪問：127.0.0.1:8080/open/something，日志如下 

2023-02-06 23:42:42.486  INFO 21168 --- [io-8200-exec-17] x.g.b.system.controller.AsyncController  : do something end, time 8 milliseconds
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-1] x.gits.boot.system.service.AsyncService  : do something, message=index = 0
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-5] x.gits.boot.system.service.AsyncService  : do something, message=index = 4
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-4] x.gits.boot.system.service.AsyncService  : do something, message=index = 3
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-6] x.gits.boot.system.service.AsyncService  : do something, message=index = 5
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-9] x.gits.boot.system.service.AsyncService  : do something, message=index = 8
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-8] x.gits.boot.system.service.AsyncService  : do something, message=index = 7
2023-02-06 23:42:42.488  INFO 21168 --- [do-something-10] x.gits.boot.system.service.AsyncService  : do something, message=index = 9
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-7] x.gits.boot.system.service.AsyncService  : do something, message=index = 6
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-2] x.gits.boot.system.service.AsyncService  : do something, message=index = 1
2023-02-06 23:42:42.488  INFO 21168 --- [ do-something-3] x.gits.boot.system.service.AsyncService  : do something, message=index = 2

由此可見已經達到異步執行的效果了，并且使用到了咱們配置的線程池。 

獲取異步方法返回值 

當異步方法有返回值時，如何獲取異步方法執行的返回結果呢？這時需要異步調用的方法帶有返回值CompletableFuture。

CompletableFuture是對Feature的增強，Feature只能處理簡單的異步任務，而CompletableFuture可以將多個異步任務進行復雜的組合。如下：

@RestController
public class AsyncController {
 
    @Autowired
    private AsyncService asyncService;
 
    @SneakyThrows
    @ApiOperation("異步 有返回值")
    @GetMapping("/open/somethings")
    public String somethings() {
        CompletableFuture<String> createOrder = asyncService.doSomething1("create order");
        CompletableFuture<String> reduceAccount = asyncService.doSomething2("reduce account");
        CompletableFuture<String> saveLog = asyncService.doSomething3("save log");
 
        // 等待所有任務都執行完
        CompletableFuture.allOf(createOrder, reduceAccount, saveLog).join();
        // 獲取每個任務的返回結果
        String result = createOrder.get() + reduceAccount.get() + saveLog.get();
        return result;
    }
}
 
 
@Slf4j
@Service
public class AsyncService {
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething1(String message) throws InterruptedException {
        log.info("do something1: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("do something1: " + message);
    }
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething2(String message) throws InterruptedException {
        log.info("do something2: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("; do something2: " + message);
    }
 
    @Async("doSomethingExecutor")
    public CompletableFuture<String> doSomething3(String message) throws InterruptedException {
        log.info("do something3: {}", message);
        Thread.sleep(1000);
        return CompletableFuture.completedFuture("; do something3: " + message);
    }
}

訪問接口 

C:\Users\Administrator>curl -X GET "http://localhost:8080/open/something"  -H "accept: */*"
do something1: create order;
do something2: reduce account;
do something3: save log

控制臺上關鍵日志如下： 

2023-02-06 00:27:42.238  INFO 5672 --- [ do-something-3] x.gits.boot.system.service.AsyncService  : do something3: save log
2023-02-06 00:27:42.238  INFO 5672 --- [ do-something-2] x.gits.boot.system.service.AsyncService  : do something2: reduce account
2023-02-06 00:27:42.238  INFO 5672 --- [ do-something-1] x.gits.boot.system.service.AsyncService  : do something1: create order

注意事項 

@Async注解會在以下幾個場景失效，也就是說明明使用了@Async注解，但就沒有走多線程。

• 異步方法使用static關鍵詞修飾；

• 異步類不是一個Spring容器的bean（一般使用注解@Component和@Service，并且能被Spring掃描到）；

• SpringBoot應用中沒有添加@EnableAsync注解；

• 在同一個類中，一個方法調用另外一個有@Async注解的方法，注解不會生效。原因是@Async注解的方法，是在代理類中執行的。

需要注意的是： 異步方法使用注解@Async的返回值只能為void或者Future及其子類，當返回結果為其他類型時，方法還是會異步執行，但是返回值都是null，部分源碼如下：

AsyncExecutionInterceptor#invoke

通過上邊幾個示例，@Async實際還是通過Future或CompletableFuture來異步執行的，Spring又封裝了一下，讓我們使用的更方便。 

到此，相信大家對“在SpringBoot怎么優雅的使用多線程”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！