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

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中反射(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 添加

Spring Boot3虚拟线程的使用步骤详解

《SpringBoot3虚拟线程的使用步骤详解》虚拟线程是Java19中引入的一个新特性,旨在通过简化线程管理来提升应用程序的并发性能,:本文主要介绍SpringBoot3虚拟线程的使用步骤,... 目录问题根源分析解决方案验证验证实验实验1:未启用keep-alive实验2:启用keep-alive扩展建

tomcat多实例部署的项目实践

《tomcat多实例部署的项目实践》Tomcat多实例是指在一台设备上运行多个Tomcat服务,这些Tomcat相互独立,本文主要介绍了tomcat多实例部署的项目实践,具有一定的参考价值,感兴趣的可... 目录1.创建项目目录,测试文China编程件2js.创建实例的安装目录3.准备实例的配置文件4.编辑实例的

springboot集成Deepseek4j的项目实践

《springboot集成Deepseek4j的项目实践》本文主要介绍了springboot集成Deepseek4j的项目实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价... 目录Deepseek4j快速开始Maven 依js赖基础配置基础使用示例1. 流式返回示例2. 进阶

Java常用注解扩展对比举例详解

《Java常用注解扩展对比举例详解》:本文主要介绍Java常用注解扩展对比的相关资料,提供了丰富的代码示例,并总结了最佳实践建议,帮助开发者更好地理解和应用这些注解,需要的朋友可以参考下... 目录一、@Controller 与 @RestController 对比二、使用 @Data 与 不使用 @Dat

SpringBoot项目启动报错"找不到或无法加载主类"的解决方法

《SpringBoot项目启动报错找不到或无法加载主类的解决方法》在使用IntelliJIDEA开发基于SpringBoot框架的Java程序时,可能会出现找不到或无法加载主类com.example.... 目录一、问题描述二、排查过程三、解决方案一、问题描述在使用 IntelliJ IDEA 开发基于

SpringBoot项目使用MDC给日志增加唯一标识的实现步骤

《SpringBoot项目使用MDC给日志增加唯一标识的实现步骤》本文介绍了如何在SpringBoot项目中使用MDC(MappedDiagnosticContext)为日志增加唯一标识,以便于日... 目录【Java】SpringBoot项目使用MDC给日志增加唯一标识,方便日志追踪1.日志效果2.实现步

Java终止正在运行的线程的三种方法

《Java终止正在运行的线程的三种方法》停止一个线程意味着在任务处理完任务之前停掉正在做的操作,也就是放弃当前的操作,停止一个线程可以用Thread.stop()方法,但最好不要用它,本文给大家介绍了... 目录前言1. 停止不了的线程2. 判断线程是否停止状态3. 能停止的线程–异常法4. 在沉睡中停止5

Ubuntu中Nginx虚拟主机设置的项目实践

《Ubuntu中Nginx虚拟主机设置的项目实践》通过配置虚拟主机,可以在同一台服务器上运行多个独立的网站,本文主要介绍了Ubuntu中Nginx虚拟主机设置的项目实践,具有一定的参考价值,感兴趣的可... 目录简介安装 Nginx创建虚拟主机1. 创建网站目录2. 创建默认索引文件3. 配置 Nginx4