如何正确的使用JDK线程池和Spring线程池

这期内容当中小编将会给大家带来有关如何正确的使用JDK线程池和Spring线程池,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。

JDK线程池和Spring线程池实例,异步调用,可以直接使用

如何正确的使用JDK线程池和Spring线程池

(1)JDK线程池的使用,此处采用单例的方式提供,见示例:

publicclassThreadPoolUtil{
	privatestaticintcorePoolSize=5;
	privatestaticintmaximumPoolSize=10;
	privatestaticlongkeepAliveTime=60L;
	privatestaticTimeUnitunit=TimeUnit.SECONDS;
	privatestaticintcapacity=1024;
	privatestaticThreadFactorynamedThreadFactory=newThreadFactoryBuilder().setNameFormat("jdk-thread-pool-%d").build();
	privatestaticfinalExecutorServiceexecutorService=newThreadPoolExecutor(corePoolSize,
	maximumPoolSize,
	keepAliveTime,
	unit,
	newLinkedBlockingQueue<>(capacity),
	namedThreadFactory,
	newThreadPoolExecutor.AbortPolicy());
	privateThreadPoolUtil(){
	}
	publicstaticExecutorServicegetExecutorService(){
		returnexecutorService;
	}
}

在其它地方可以直接这样使用:

ThreadPoolUtil.getExecutorService().execute(()->{
	System.out.println("test1");
	System.out.println("test2");
}
)

(2)Spring线程池的使用,此处通过配置类的方式配置线程池的相关属性,见示例:

@Configuration
@EnableAsync
publicclassDocataThreadBeanConfig{
	privateintcorePoolSize=5;
	privateintmaxPoolSize=10;
	privateintqueueCapacity=1024;
	privateStringnamePrefix="async-service-task-";
	//上述属性可以通过@Value来读取配置值
	@Bean(name="asyncServiceTaskExecutor")
	publicTaskExecutorasyncServiceExecutor(){
		ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor();
		//设置核心线程数
		executor.setCorePoolSize(corePoolSize);
		//设置最大线程数
		executor.setMaxPoolSize(maxPoolSize);
		//设置队列容量
		executor.setQueueCapacity(queueCapacity);
		//设置线程活跃时间(秒)
		executor.setKeepAliveSeconds(60);
		//设置默认线程名称
		executor.setThreadNamePrefix(namePrefix);
		//设置拒绝策略
		executor.setRejectedExecutionHandler(newThreadPoolExecutor.CallerRunsPolicy());
		//等待所有任务结束后再关闭线程池
		executor.setWaitForTasksToCompleteOnShutdown(true);
		executor.initialize();
		;
		returnexecutor;
	}
}

在其它文件中需要这样使用:

@Resource(name="asyncServiceTaskExecutor")
privateThreadPoolTaskExecutorasyncServiceTaskExecutor;

不要直接使用@Autowired,否则会提示失败的

@Autowired
privateThreadPoolTaskExecutorasyncServiceTaskExecutor;

上述就是小编为大家分享的如何正确的使用JDK线程池和Spring线程池了,如果刚好有类似的疑惑,不妨参照上述分析进行理解。如果想知道更多相关知识,欢迎关注恰卡编程网行业资讯频道。

发布于 2021-03-24 01:21:40
收藏
分享
海报
0 条评论
169
上一篇:怎么在Java中使用HashMap并查集 下一篇:怎么在Java项目中使用POI导出Excel数据
目录

    0 条评论

    本站已关闭游客评论,请登录或者注册后再评论吧~

    忘记密码?

    图形验证码