JDK线程池和Spring线程池的使用实例介绍

本篇内容主要讲解“JDK线程池和Spring线程池的使用实例介绍”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“JDK线程池和Spring线程池的使用实例介绍”吧!

成都创新互联公司成立于2013年,我们提供高端成都网站建设网站制作网站设计、网站定制、成都全网营销小程序设计、微信公众号开发、成都网站推广服务,提供专业营销思路、内容策划、视觉设计、程序开发来完成项目落地,为成都社区文化墙企业提供源源不断的流量和订单咨询。

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@EnableAsyncpublic 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,否则会提示失败的

@Autowiredprivate ThreadPoolTaskExecutor asyncServiceTaskExecutor;

到此,相信大家对“JDK线程池和Spring线程池的使用实例介绍”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!


分享名称:JDK线程池和Spring线程池的使用实例介绍
本文地址:http://scyanting.com/article/gdoeps.html