SpringBoot多线程环境下,解决多个定时器冲突问题
欢迎关注方志朋的博客,回复”666“获面试宝典
来源:blog.csdn.net/cssnnd/article/details/108328942
战术分析:
实际开发项目中一定不止一个定时器,很多场景都需要用到,而多个定时器带来的问题 : 就是如何避免多个定时器的互相冲突
使用场景 :
我们的订单服务,一般会有一个待支付订单,而这个待支付订单是有时间限制的,比如阿里巴巴的订单是五天,淘宝订单是一天,拼多多订单是一天,美团订单是15分钟…
基金系统中,如何同时更新多个存储分区中的基金信息…
总的来说,实际开发中定时器需要解决多个定时器同时并发的问题,也要解决定时器之间的冲突问题
问题不大,说到并发那就离不开多线程了…慢慢看看就懂了
问题场景重现 :
我们清晰的看到执行结果都是scheduling-1
就此可以判定,Springboot定时器默认的是单线程的
但是问题就来了,如果在线程争夺资源后,某个线程需要比较长时间才能执行完,那其他的定时器怎么办,都只能进入等待状态,时间越久,累计等待的定时器越多,这就容易引起雪崩…
其实只需要添加一个配置类然后加注解就可以解决问题了
添加注解
具体代码如下 :
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;
import java.util.Date;@Component
public class SchedulerTaskController {private Logger logger= LoggerFactory.getLogger(SchedulerTaskController.class);private static final SimpleDateFormat dateFormat=new SimpleDateFormat("HH:mm:ss");private int count=0;@Scheduled(cron="*/6 * * * * ?")@Async("threadPoolTaskExecutor")public void process(){logger.info("英文:this is scheduler task runing "+(count++));}@Scheduled(fixedRate = 6000)@Async("threadPoolTaskExecutor")public void currentTime(){logger.info("中文:现在时间"+dateFormat.format(new Date()));}
}
配置类如下 :
具体代码如下 :
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.ThreadPoolExecutor;/**使用多线程的时候,往往需要创建Thread类,或者实现Runnable接口,如果要使用到线程池,我们还需要来创建Executors,* 在使用spring中,已经给我们做了很好的支持。只要要@EnableAsync就可以使用多线程* 通过spring给我们提供的ThreadPoolTaskExecutor就可以使用线程池。*/
//@Configuration 表示该类是一个配置类
@Configuration
@EnableAsync
//所有的定时任务都放在一个线程池中,定时任务启动时使用不同都线程。
public class TaskScheduleConfig {private static final int corePoolSize = 10; // 默认线程数private static final int maxPoolSize = 100; // 最大线程数private static final int keepAliveTime = 10; // 允许线程空闲时间(单位:默认为秒),十秒后就把线程关闭private static final int queueCapacity = 200; // 缓冲队列数private static final String threadNamePrefix = "it-is-threaddemo-"; // 线程池名前缀@Bean("threadPoolTaskExecutor") // bean的名称,默认为首字母小写的方法名public ThreadPoolTaskExecutor getDemoThread(){ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(corePoolSize);executor.setMaxPoolSize(maxPoolSize);executor.setQueueCapacity(keepAliveTime);executor.setKeepAliveSeconds(queueCapacity);executor.setThreadNamePrefix(threadNamePrefix);//线程池拒绝任务的处理策略executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//初始化executor.initialize();return executor;}
}
然后我们可以很清晰地看到
如上,也就解决了用多线程解决Springboot多定时器冲突的问题
热门内容:
国内最牛逼的笔记,不接受反驳!!
顶配版阿里大佬面试笔记+300道硬核面试题,跪着啃完了。。。。
阿里二面:GET 请求能传图片吗?
别再用 BeanUtils 了,这款 PO VO DTO 转换神器不香么?
抗住双11超高并发,今年排第一的调优方案,没有之一!
最近面试BAT,整理一份面试资料《Java面试BAT通关手册》,覆盖了Java核心技术、JVM、Java并发、SSM、微服务、数据库、数据结构等等。
获取方式:点“在看”,关注公众号并回复 666 领取,更多内容陆续奉上。
明天见(。・ω・。)ノ♡
SpringBoot多线程环境下,解决多个定时器冲突问题相关推荐
- 多线程环境下海量定时任务的定时器设计丨时间轮实现丨红黑树,跳表分析
多线程环境下海量定时任务定时器设计 1. 定时器分析 2. 红黑树,最小堆,跳表实现比较分析 3. 时间轮实现 [Linux后端开发系列]多线程环境下海量定时任务的定时器设计丨时间轮实现丨红黑树,跳表 ...
- 技术精讲丨多线程环境下时间轮-海量定时任务的定时器设计
多线程环境下海量定时任务处理-定时器设计 1. 定时器设计 2. 红黑树.最小堆以及跳表的实现对比 3. 时间轮的实现 视频讲解如下,点击观看: 技术精讲丨多线程环境下时间轮-海量定时任务的定时 ...
- 多线程环境下的线程不安全问题(1)
在不考虑多线程的情况下,很多类代码都是完全正确的,但是如果放在多线程环境下,这些代码就很容易出错,我们称这些类为 线程不安全类 .多线程环境下使用线程安全类 才是安全的. 下面是一个线程不安全类的例子 ...
- Java多线程之单例模式在多线程环境下的安全问题
Java多线程之单例模式在多线程环境下的安全问题 目录: 单例模式基本概念 单线程下的单例模式 多线程下的单例模式 单例模式volatile分析 1. 单例模式基本概念 基本概念转载自:单例模式|菜鸟 ...
- 多线程环境下HashMap导致CPU100%
引言 昨天早上线上系统开始作业了一段时间以后,突然收到服务器报警,服务器CPU持续占用100%,导致线上系统不能正常使用,我登录服务器top了一下,发现java进程占用cpu400%, 由于前天晚上上 ...
- HttpClient在多线程环境下踩坑总结
HttpClient在多线程环境下踩坑总结 问题现场 在多线程环境下使用HttpClient组件对某个HTTP服务发起请求,运行一段时间之后发现客户端主机CPU利用率呈现出下降趋势,而不是一个稳定的状 ...
- php-cgi和php-fpm,Windows环境下解决Nginx+php并发访问阻塞问题。
php-cgi 是运行php, php-fpm是守护php-cgi进程 nginx配置目录运行php location ~ \.php$ { ...
- Win10 + VS2017 15.5.6 环境下解决 Python 3.6 环境无法刷新DB的问题
Win10 + VS2017 15.5.6 环境下解决 Python 3.6 环境无法刷新DB的问题 参考文章: (1)Win10 + VS2017 15.5.6 环境下解决 Python 3.6 环 ...
- 多线程环境下,程序真是危机四伏
姿势在不断的更新迭代, 太卷了. 你管这也叫线程安全? 最近大意了,竟然想将<面试官:实现一个带值变更通知能力的Dictionary>一文中的临界锁只应用到写操作. 内心旁白:读操作又不会 ...
最新文章
- 2022-2028年中国侧线油行业市场研究及前瞻分析报告
- TX2---ORB_SLAM2
- 微信防撤回python代码_Python实现微信防撤回
- SQL、LINQ、Lambda 三种用法(转)
- Oracle入门(十)之概要文件
- c++ queue学习
- linux c 网络编程与信号量,linux网络编程-----线程同步--信号量
- [BZOJ3555] [Ctsc2014]企鹅QQ(Hash)
- android手机charles证书下载
- 如何删除360的防火墙模块(详解)
- 浅谈 MyBatis 缓存
- Navicat Premium 历史版本地址
- 益智拼图APP隐私政策
- ubuntu22 使用todesk被远程控制时显示黑屏或者白屏
- SpringBoot+JavaMailSender+ 腾讯企业邮箱配置
- SPSS教程之生存分析的Cox回归模型(比例风险模型)
- 一个互联网app的开发设计(技术选型和架构)
- ESP8266 Blinker RGB三色灯控制
- 【ChatBot】走进聊天机器人
- NetLogo 初步认识