JDK线程池和Spring线程池的使用实例解析

 更新时间:2019年11月29日 14:36:57   作者:晒太阳的兔子  
这篇文章主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了JDK线程池和Spring线程池的使用实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

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;

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • 详谈Java编程之委托代理回调、内部类以及匿名内部类回调(闭包回调)

    详谈Java编程之委托代理回调、内部类以及匿名内部类回调(闭包回调

    下面小编就为大家带来一篇详谈Java编程之委托代理回调、内部类以及匿名内部类回调(闭包回调)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-05-05
  • SpringBoot项目访问任意接口出现401错误的解决方案

    SpringBoot项目访问任意接口出现401错误的解决方案

    今天小编就为大家分享一篇关于SpringBoot项目访问任意接口出现401错误的解决方案,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-01-01
  • Java编程rabbitMQ实现消息的收发

    Java编程rabbitMQ实现消息的收发

    RabbitMQ是一个在AMQP基础上完成的,可复用的企业消息系统,本文通过实例来给大家分享通过操作rabbitMQ实现消息的收发,感兴趣的朋友可以参考下。
    2017-09-09
  • Idea防沉迷插件StopCoding的安装使用教程

    Idea防沉迷插件StopCoding的安装使用教程

    这篇文章主要介绍了Idea防沉迷插件StopCoding的安装使用教程,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-01-01
  • java char数据类型原理解析

    java char数据类型原理解析

    这篇文章主要介绍了java char数据类型原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • J2SE基础之下载eclipse并创建项目

    J2SE基础之下载eclipse并创建项目

    本文给大家介绍的是最流行的java 集成开发环境IDE eclipse的使用方法,非常的简单,有需要的小伙伴可以参考下
    2016-05-05
  • MP(MyBatis-Plus)实现乐观锁更新功能的示例代码

    MP(MyBatis-Plus)实现乐观锁更新功能的示例代码

    这篇文章主要介绍了MP(MyBatis-Plus)实现乐观锁更新功能的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-01-01
  • Spring Data JPA使用JPQL与原生SQL进行查询的操作

    Spring Data JPA使用JPQL与原生SQL进行查询的操作

    这篇文章主要介绍了Spring Data JPA使用JPQL与原生SQL进行查询的操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • Java不能真正泛型的原因是什么?

    Java不能真正泛型的原因是什么?

    今天我来给大家讲一下,Java 不能实现真正泛型的原因是什么?感兴趣的朋友可以看一下,如果能给你到来一些帮助,请关注小编的其他内容
    2021-08-08
  • Java自带的加密类MessageDigest类代码示例

    Java自带的加密类MessageDigest类代码示例

    这篇文章主要介绍了Java自带的加密类MessageDigest类代码示例,分享了常见的三种加密方式代码示例,具有一定参考价值,需要的朋友可以了解下。
    2017-11-11

最新评论