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

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

相关文章

将Java项目提交到云服务器的流程步骤

《将Java项目提交到云服务器的流程步骤》所谓将项目提交到云服务器即将你的项目打成一个jar包然后提交到云服务器即可,因此我们需要准备服务器环境为:Linux+JDK+MariDB(MySQL)+Gi... 目录1. 安装 jdk1.1 查看 jdk 版本1.2 下载 jdk2. 安装 mariadb(my

Node.js 数据库 CRUD 项目示例详解(完美解决方案)

《Node.js数据库CRUD项目示例详解(完美解决方案)》:本文主要介绍Node.js数据库CRUD项目示例详解(完美解决方案),本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考... 目录项目结构1. 初始化项目2. 配置数据库连接 (config/db.js)3. 创建模型 (models/

Python中局部变量和全局变量举例详解

《Python中局部变量和全局变量举例详解》:本文主要介绍如何通过一个简单的Python代码示例来解释命名空间和作用域的概念,它详细说明了内置名称、全局名称、局部名称以及它们之间的查找顺序,文中通... 目录引入例子拆解源码运行结果如下图代码解析 python3命名空间和作用域命名空间命名空间查找顺序命名空

springboot项目中常用的工具类和api详解

《springboot项目中常用的工具类和api详解》在SpringBoot项目中,开发者通常会依赖一些工具类和API来简化开发、提高效率,以下是一些常用的工具类及其典型应用场景,涵盖Spring原生... 目录1. Spring Framework 自带工具类(1) StringUtils(2) Coll

Java中使用Hutool进行AES加密解密的方法举例

《Java中使用Hutool进行AES加密解密的方法举例》AES是一种对称加密,所谓对称加密就是加密与解密使用的秘钥是一个,下面:本文主要介绍Java中使用Hutool进行AES加密解密的相关资料... 目录前言一、Hutool简介与引入1.1 Hutool简介1.2 引入Hutool二、AES加密解密基础

Spring Boot项目部署命令java -jar的各种参数及作用详解

《SpringBoot项目部署命令java-jar的各种参数及作用详解》:本文主要介绍SpringBoot项目部署命令java-jar的各种参数及作用的相关资料,包括设置内存大小、垃圾回收... 目录前言一、基础命令结构二、常见的 Java 命令参数1. 设置内存大小2. 配置垃圾回收器3. 配置线程栈大小

Spring Boot项目中结合MyBatis实现MySQL的自动主从切换功能

《SpringBoot项目中结合MyBatis实现MySQL的自动主从切换功能》:本文主要介绍SpringBoot项目中结合MyBatis实现MySQL的自动主从切换功能,本文分步骤给大家介绍的... 目录原理解析1. mysql主从复制(Master-Slave Replication)2. 读写分离3.

C语言函数递归实际应用举例详解

《C语言函数递归实际应用举例详解》程序调用自身的编程技巧称为递归,递归做为一种算法在程序设计语言中广泛应用,:本文主要介绍C语言函数递归实际应用举例的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录前言一、递归的概念与思想二、递归的限制条件 三、递归的实际应用举例(一)求 n 的阶乘(二)顺序打印

java中反射(Reflection)机制举例详解

《java中反射(Reflection)机制举例详解》Java中的反射机制是指Java程序在运行期间可以获取到一个对象的全部信息,:本文主要介绍java中反射(Reflection)机制的相关资料... 目录一、什么是反射?二、反射的用途三、获取Class对象四、Class类型的对象使用场景1五、Class

一文教你如何将maven项目转成web项目

《一文教你如何将maven项目转成web项目》在软件开发过程中,有时我们需要将一个普通的Maven项目转换为Web项目,以便能够部署到Web容器中运行,本文将详细介绍如何通过简单的步骤完成这一转换过程... 目录准备工作步骤一:修改​​pom.XML​​1.1 添加​​packaging​​标签1.2 添加