直接貼代碼
自定義線程池
package com.xh.lawsuit.rest.modular.example;
?
?
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
?
import java.util.concurrent.Executor;
?
@Configuration
public class GlobalThreadPool {
? ? @Bean
? ? public Executor taskExecutor() {
? ? ? ? int cpuCount = Runtime.getRuntime().availableProcessors() ;
?
? ? ? ? int coreThreadSize = cpuCount << 1;
?
? ? ? ? int maxThreadSize = cpuCount << 4;
? ? ? ? ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
? ? ? ? executor.setCorePoolSize(coreThreadSize);
? ? ? ? executor.setMaxPoolSize(maxThreadSize);
? ? ? ? executor.setQueueCapacity(5000);
? ? ? ? executor.setThreadNamePrefix("Java同學會-");
? ? ? ? executor.initialize();
? ? ? ? return executor;
? ? }
}
異步的service
package com.xh.lawsuit.rest.modular.example;
?
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
?
import java.util.concurrent.CompletableFuture;
?
/**
?* @author felix
?* @data 2020/1/19 0019 16:55
?*/
@EnableAsync
@Service
@Slf4j
public class BusyService {
? ? @Async
? ? public CompletableFuture<String> busyMethod(String name) throws InterruptedException {
? ? ? ? log.info(name);
? ? ? ? String s = "Hello,"+name+"!";
? ? ? ? //模擬耗時操作，5秒
? ? ? ? Thread.sleep(5000);
? ? ? ? return CompletableFuture.completedFuture(s);
? ? }
}
測試類測試程序
@Test
? ? public void test() throws InterruptedException, ExecutionException {
? ? ? ? long start = System.currentTimeMillis();
? ? ? ? CompletableFuture<String> jane = busyService.busyMethod("Jane");
? ? ? ? CompletableFuture<String> allen = busyService.busyMethod("Allen");
? ? ? ? CompletableFuture<String> james = busyService.busyMethod("James");
? ? ? ? CompletableFuture.allOf(jane,allen,james).join();
? ? ? ? log.info(jane.get());
? ? ? ? log.info(allen.get());
? ? ? ? log.info(james.get());
? ? ? ? long end = System.currentTimeMillis();
? ? ? ? log.info("最終耗時="+(end-start));
? ? }
輸出結果，時間為5010毫秒，異步執行成功
————————————————
版權聲明：本文為CSDN博主「leigelg」的原創文章，遵循CC 4.0 BY-SA版權協議，轉載請附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/leigelg/article/details/104043899
)
