实验室横向项目线程池涉及举例

2024-08-31 07:58

本文主要是介绍实验室横向项目线程池涉及举例,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

遇到问题:

有一条订单流水在数据库中出现两次。

原因:

简单来说就是在并发情况下没有做数据唯一性处理,不管怎么样这类并发情况都是有必要的处理。

解决方式:使用线程池+队列

1.写一个Controller(Spring mvc)

/*** @author ghq* @date 2018/6/1* @description*/
@Controller
public class ThreadPoolController {@AutowiredThreadPoolManager tpm;@RequestMapping("/pool")public@ResponseBodyObject test() {for (int i = 0; i < 500; i++) {//模拟并发500条记录tpm.processOrders(Integer.toString(i));}return "ok";}
}

 

2.线程池管理

/*** @author ghq* @date 2018/6/1* @description threadPool订单线程池, 处理订单* scheduler 调度线程池 用于处理订单线程池由于超出线程范围和队列容量而不能处理的订单*/
@Component
public class ThreadPoolManager implements BeanFactoryAware {private static Logger log = LoggerFactory.getLogger(ThreadPoolManager.class);private BeanFactory factory;//用于从IOC里取对象// 线程池维护线程的最少数量private final static int CORE_POOL_SIZE = 2;// 线程池维护线程的最大数量private final static int MAX_POOL_SIZE = 10;// 线程池维护线程所允许的空闲时间private final static int KEEP_ALIVE_TIME = 0;// 线程池所使用的缓冲队列大小private final static int WORK_QUEUE_SIZE = 50;// 消息缓冲队列Queue<Object> msgQueue = new LinkedList<Object>();//用于储存在队列中的订单,防止重复提交Map<String, Object> cacheMap = new ConcurrentHashMap<>();//由于超出线程范围和队列容量而使执行被阻塞时所使用的处理程序final RejectedExecutionHandler handler = new RejectedExecutionHandler() {@Overridepublic void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {//System.out.println("太忙了,把该订单交给调度线程池逐一处理" + ((DBThread) r).getMsg());msgQueue.offer(((DBThread) r).getMsg());}};// 订单线程池final ThreadPoolExecutor threadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME,TimeUnit.SECONDS, new ArrayBlockingQueue(WORK_QUEUE_SIZE), this.handler);// 调度线程池。此线程池支持定时以及周期性执行任务的需求。final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5);// 访问消息缓存的调度线程,每秒执行一次// 查看是否有待定请求,如果有,则创建一个新的AccessDBThread,并添加到线程池中final ScheduledFuture taskHandler = scheduler.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {if (!msgQueue.isEmpty()) {if (threadPool.getQueue().size() < WORK_QUEUE_SIZE) {System.out.print("调度:");String orderId = (String) msgQueue.poll();DBThread accessDBThread = (DBThread) factory.getBean("dBThread");accessDBThread.setMsg(orderId);threadPool.execute(accessDBThread);}// while (msgQueue.peek() != null) {// }}}}, 0, 1, TimeUnit.SECONDS);//终止订单线程池+调度线程池public void shutdown() {//true表示如果定时任务在执行,立即中止,false则等待任务结束后再停止System.out.println(taskHandler.cancel(false));scheduler.shutdown();threadPool.shutdown();}public Queue<Object> getMsgQueue() {return msgQueue;}//将任务加入订单线程池public void processOrders(String orderId) {if (cacheMap.get(orderId) == null) {cacheMap.put(orderId,new Object());DBThread accessDBThread = (DBThread) factory.getBean("dBThread");accessDBThread.setMsg(orderId);threadPool.execute(accessDBThread);}}//BeanFactoryAware@Overridepublic void setBeanFactory(BeanFactory beanFactory) throws BeansException {factory = beanFactory;}
}

3.线程池中工作的线程

//线程池中工作的线程
@Component
@Scope("prototype")//spring 多例
public class DBThread implements Runnable {private String msg;private Logger log = LoggerFactory.getLogger(DBThread.class);@AutowiredSystemLogService systemLogService;@Overridepublic void run() {//模拟在数据库插入数据Systemlog systemlog = new Systemlog();systemlog.setTime(new Date());systemlog.setLogdescribe(msg);//systemLogService.insert(systemlog);log.info("insert->" + msg);}public String getMsg() {return msg;}public void setMsg(String msg) {this.msg = msg;}
}

 

浏览器输入地址127.0.0.1/pool

几秒后关闭tomcat。

模拟500条数据,订单线程池处理了117条。调度线程池处理5条

关闭tomcat,后还有378条未处理(这里的实现需要用到spring监听器)。加起来一共500

OK。完毕

spring监听器,监听tomcat关闭事件:

public class MyApplicationListener implements ApplicationListener<ApplicationEvent> {@AutowiredThreadPoolManager threadPoolManager;@Overridepublic void onApplicationEvent(ApplicationEvent event) {if (event instanceof ContextClosedEvent) {XmlWebApplicationContext x = (XmlWebApplicationContext) event.getSource();//防止执行两次。root application context 没有parent,他就是老大if (x.getDisplayName().equals("Root WebApplicationContext")) {threadPoolManager.shutdown();Queue q = threadPoolManager.getMsgQueue();System.out.println("关闭了服务器,还有未处理的信息条数:" + q.size());}} else if (event instanceof ContextRefreshedEvent) {
//            System.out.println(event.getClass().getSimpleName()+" 事件已发生!");} else if (event instanceof ContextStartedEvent) {
//            System.out.println(event.getClass().getSimpleName()+" 事件已发生!");} else if (event instanceof ContextStoppedEvent) {
//            System.out.println(event.getClass().getSimpleName()+" 事件已发生!");} else {
//            System.out.println("有其它事件发生:"+event.getClass().getName());}}
}

spring配置一下

<bean id="springStartListener" class="com.temp.MyApplicationListener"></bean>

这篇关于实验室横向项目线程池涉及举例的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1123323

相关文章

Javaee多线程之进程和线程之间的区别和联系(最新整理)

《Javaee多线程之进程和线程之间的区别和联系(最新整理)》进程是资源分配单位,线程是调度执行单位,共享资源更高效,创建线程五种方式:继承Thread、Runnable接口、匿名类、lambda,r... 目录进程和线程进程线程进程和线程的区别创建线程的五种写法继承Thread,重写run实现Runnab

SpringBoot线程池配置使用示例详解

《SpringBoot线程池配置使用示例详解》SpringBoot集成@Async注解,支持线程池参数配置(核心数、队列容量、拒绝策略等)及生命周期管理,结合监控与任务装饰器,提升异步处理效率与系统... 目录一、核心特性二、添加依赖三、参数详解四、配置线程池五、应用实践代码说明拒绝策略(Rejected

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

深度解析Java项目中包和包之间的联系

《深度解析Java项目中包和包之间的联系》文章浏览阅读850次,点赞13次,收藏8次。本文详细介绍了Java分层架构中的几个关键包:DTO、Controller、Service和Mapper。_jav... 目录前言一、各大包1.DTO1.1、DTO的核心用途1.2. DTO与实体类(Entity)的区别1

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,:本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释?示例:三、单行注释语法:以 China编程# 开头,后面的内容为注释内容示例:示例:四

如何在Spring Boot项目中集成MQTT协议

《如何在SpringBoot项目中集成MQTT协议》本文介绍在SpringBoot中集成MQTT的步骤,包括安装Broker、添加EclipsePaho依赖、配置连接参数、实现消息发布订阅、测试接口... 目录1. 准备工作2. 引入依赖3. 配置MQTT连接4. 创建MQTT配置类5. 实现消息发布与订阅

springboot项目打jar制作成镜像并指定配置文件位置方式

《springboot项目打jar制作成镜像并指定配置文件位置方式》:本文主要介绍springboot项目打jar制作成镜像并指定配置文件位置方式,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录一、上传jar到服务器二、编写dockerfile三、新建对应配置文件所存放的数据卷目录四、将配置文

怎么用idea创建一个SpringBoot项目

《怎么用idea创建一个SpringBoot项目》本文介绍了在IDEA中创建SpringBoot项目的步骤,包括环境准备(JDK1.8+、Maven3.2.5+)、使用SpringInitializr... 目录如何在idea中创建一个SpringBoot项目环境准备1.1打开IDEA,点击New新建一个项

springboot项目中整合高德地图的实践

《springboot项目中整合高德地图的实践》:本文主要介绍springboot项目中整合高德地图的实践,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一:高德开放平台的使用二:创建数据库(我是用的是mysql)三:Springboot所需的依赖(根据你的需求再

一文详解如何在idea中快速搭建一个Spring Boot项目

《一文详解如何在idea中快速搭建一个SpringBoot项目》IntelliJIDEA作为Java开发者的‌首选IDE‌,深度集成SpringBoot支持,可一键生成项目骨架、智能配置依赖,这篇文... 目录前言1、创建项目名称2、勾选需要的依赖3、在setting中检查maven4、编写数据源5、开启热