Java线程池ExecutorService和Executors应用(Spring Boot微服务)
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Configuration
@EnableAsync
public class AsyncConfig {
// 创建一个固定大小的线程池
@Bean(name = "threadPoolTaskExecutor")
public ExecutorService threadPoolTaskExecutor() {
return Executors.newFixedThreadPool(10); // 可以根据需要调整线程池大小
}
}
这段代码定义了一个配置类AsyncConfig
,使用@EnableAsync
注解开启Spring的异步方法执行功能。它还定义了一个名为threadPoolTaskExecutor
的Bean,该Bean是一个ExecutorService
类型,使用Executors.newFixedThreadPool(10)
创建了一个固定大小为10的线程池。在Spring Boot微服务中,可以将此Bean注入到需要异步执行任务的组件中,并使用@Async
注解标记异步方法。
评论已关闭