Hi，大家好，我是编程小6，很荣幸遇见你，我把这些年在开发过程中遇到的问题或想法写出来，今天说一说
springboot nio 线程池_java线程池的使用例子,希望能够帮助你!!!。

Springboot线程池配置管理

1. 线程池配置类

package com.bin.kong.csdnspider.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.task.AsyncTaskExecutor; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import java.util.concurrent.ThreadPoolExecutor; @Configuration @EnableAsync public class ThreadPoolConfig { private int corePoolSize = 10;//线程池维护线程的最少数量 private int maxPoolSize = 50;//线程池维护线程的最大数量 private int queueCapacity = 20; //缓存队列 private int keepAlive = 120;//允许的空闲时间 @Bean public AsyncTaskExecutor threadExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(corePoolSize); executor.setMaxPoolSize(maxPoolSize); executor.setQueueCapacity(queueCapacity); executor.setThreadNamePrefix("threadExecutor-"); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); //对拒绝task的处理策略 executor.setKeepAliveSeconds(keepAlive); executor.initialize(); return executor; } } 

配置说明：

2.线程池的使用

在类中的方法名上使用：@Async(“threadExecutor”) 即可达到使用线程池的效果
示例如下：

package com.bin.kong.csdnspider.utils; import org.springframework.scheduling.annotation.Async; @Service public class TestThreadPool { @Async("threadExecutor") public void exec() { System.out.println("当前线程名："+Thread.currentThread().getName()); } } 

测试打印结果如下：

当前线程名：threadExecutor-1

今天的分享到此就结束了，感谢您的阅读，如果确实帮到您，您可以动动手指转发给其他人。