使用SPRING中的线程池ThreadPoolTaskExecutor实现并发。
一:不需要返回值的情况
1,初始化线程池
ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
poolTaskExecutor.setQueueCapacity(10000);
poolTaskExecutor.setCorePoolSize(5);
poolTaskExecutor.setMaxPoolSize(10);
poolTaskExecutor.setKeepAliveSeconds(5000);
poolTaskExecutor.initialize();
2,在线程池中执行某个线程
poolTaskExecutor.execute(new Thread(Objct...){...});
二:需要返回值的情况
1,初始化线程池poolTaskExecutor,同上
2,新建一个类,实现Callable接口
class GetFromDB implements Callable<User> {
private UserDao userDao;
private Long userId;
public GetFromDB(UserDao userDao, Long userId) {
this.userDao = userDao;
this.userId = userId;
}
public User call() throws DaoException {
User user = userDao.getUserById(userId);
return user;
}
}
3,用之前的GetFromDB类构造一个FutureTask类
FutureTask<User> dbtask = new FutureTask<User>(GetFromDB);
4,提交并执行
threadpool.submit(dbtask);
5,得到返回值
try {
User user = dbtask.get();
} catch (Exception e) {
if (e instanceof ExecutionException
&& ((ExecutionException) e).getCause() instanceof DaoException) {
throw (DaoException) ((ExecutionException) e).getCause();
} else {
其他处理方式
}
}
注:一旦调用了get()方法,如果线程还未产生返回值,则将阻塞get()方法,直到得到返回值。基于此,如果你想确保线程执行完后才执行下一步操作,即使你不想得到返回值也可以调用一下此方法。当然这与多线程的初衷不符。
分享到:
相关推荐
springmvc+spring线程池处理http并发请求数据同步控制问题
本篇文章主要介绍了Spring线程池ThreadPoolTaskExecutor配置详情,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Spring中的同步执行器 1. SyncTaskExecutor:同步可以用SyncTaskExecutor,但这个可以说不算一个线程池,因为还在原线程执行。这个类没有实现异步调用,只是一个同步操作。 2.也可以用ThreadPoolTaskExecutor结合...
大型电商项目实战1:Redis+Rest+Linux+Nginx+Spring+SpringMVC实现JAVA高并发秒杀系统,baidu链接,谢谢
主要介绍了Spring Boot整合FTPClient线程池的实现示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
ActiveMQ与Spring线程池整合的一个实例。 lib库没有上传。 对于实例的讲解,在竹子的论坛有我对这个实例的帖子(http://www.java2000.net/viewthread.jsp?tid=1167) lib中包含: apache-activemq-4.1.1.jar ...
今天小编就为大家分享一篇关于在spring boot中使用java线程池ExecutorService的讲解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
毕设项目:基于spring+mybatis实现高并发秒杀系统,包含详细笔记 毕设项目:基于spring+mybatis实现高并发秒杀系统,包含详细笔记 毕设项目:基于spring+mybatis实现高并发秒杀系统,包含详细笔记 毕设项目:基于...
线程池例子线程池例子线程池例子线程池例子
NULL 博文链接:https://bijian1013.iteye.com/blog/2368708
Spring Boot 线程池的创建、@Async 配置步骤及注意事项
主要介绍了Spring Boot使用Spring的异步线程池的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
Spring原理 2 Spring ioc 原理 3 Bean生命周期 3 Java反射 4 beanfactory和applicationcontext 5 类装载器ClassLoader 6 Spring aop 原理 6 Aop代理 7 Spring 事物 10 ...Spring TaskExecutor线程池 16
使用spring线程池多线程并发处理大批量数据,解决IO效率问题。
Java中的阻塞队列原理与使用.mp4 实战:简单实现消息队列.mp4 并发容器ConcurrentHashMap原理与使用.mp4 线程池的原理与使用.mp4 Executor框架详解.mp4 实战:简易web服务器(一).mp4 实战:简易web服务器(二)....
Spring3.2.6定时任务+线程池,实现系统后台任务多线程处理
java线程池处理多并发,所有进程执行完后再统一处理结果线程池配置类多线程并行demo 线程池配置类 import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation....
Java与spring-boot实现分布式高并发秒杀系统
NULL 博文链接:https://hoochiang.iteye.com/blog/2249733
【资源说明】 1、该资源包括项目的全部源码,下载可以直接使用! 2、本项目适合作为计算机、数学、电子信息等专业的课程设计、...基于spring+mybatis实现高并发秒杀系统源码+项目说明(包含详细笔记)(高分毕设).zip