13518219792
这期内容当中小编将会给大家带来有关如何正确的使用JDK线程池和Spring线程池，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。
成都创新互联公司专业为企业提供界首网站建设、界首做网站、界首网站设计、界首网站制作等企业网站建设、网页设计与制作、界首企业网站模板建站服务，10多年界首做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。
JDK线程池和Spring线程池实例，异步调用，可以直接使用
(1)JDK线程池的使用，此处采用单例的方式提供，见示例：
public class ThreadPoolUtil {
private static int corePoolSize = 5;
private static int maximumPoolSize = 10;
private static long keepAliveTime = 60L;
private static TimeUnit unit = TimeUnit.SECONDS;
private static int capacity = 1024;
private static ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("jdk-thread-pool-%d").build();
private static final ExecutorService executorService = new ThreadPoolExecutor(corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
new LinkedBlockingQueue<>(capacity),
namedThreadFactory,
new ThreadPoolExecutor.AbortPolicy());
private ThreadPoolUtil () {
}
public static ExecutorService getExecutorService () {
return executorService;
}
}在其它地方可以直接这样使用：
ThreadPoolUtil.getExecutorService().execute(() -> {
System.out.println("test1");
System.out.println("test2");
}
)(2)Spring线程池的使用，此处通过配置类的方式配置线程池的相关属性，见示例：
@Configuration
@EnableAsync
public class DocataThreadBeanConfig {
private int corePoolSize = 5;
private int maxPoolSize = 10;
private int queueCapacity = 1024;
private String namePrefix = "async-service-task-";
// 上述属性可以通过@Value来读取配置值
@Bean(name = "asyncServiceTaskExecutor")
public TaskExecutor asyncServiceExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 设置核心线程数
executor.setCorePoolSize(corePoolSize);
// 设置最大线程数
executor.setMaxPoolSize(maxPoolSize);
// 设置队列容量
executor.setQueueCapacity(queueCapacity);
// 设置线程活跃时间（秒）
executor.setKeepAliveSeconds(60);
// 设置默认线程名称
executor.setThreadNamePrefix(namePrefix);
// 设置拒绝策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任务结束后再关闭线程池
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.initialize();
;
return executor;
}
}在其它文件中需要这样使用：
@Resource(name="asyncServiceTaskExecutor") private ThreadPoolTaskExecutor asyncServiceTaskExecutor;
不要直接使用@Autowired，否则会提示失败的
@Autowired private ThreadPoolTaskExecutor asyncServiceTaskExecutor;
上述就是小编为大家分享的如何正确的使用JDK线程池和Spring线程池了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注创新互联行业资讯频道。
