一次 HashSet 所引起的并发问题(下)

简介: 首先了解下这个应用大概是做什么的。 简单来说就是从 MQ 中取出数据然后丢到后面的业务线程池中做具体的业务处理。 而报警的队列正好就是这个线程池的队列。

已经很明显了。这里在遍历链表,同时由于形成了环形链表导致这个 e.next 永远不为空,所以这个循环也不会退出了。


到这里其实已经找到问题了,但还有一个疑问是为什么线程池里的任务队列会越堆越多。我第一直觉是任务执行太慢导致的。


仔细查看了代码发现只有一个地方可能会慢:也就是有一个数据库的查询


把这个 SQL 拿到生产环境执行发现确实不快,查看索引发现都有命中。


但我一看表中的数据发现已经快有 7000W 的数据了。同时经过运维得知 MySQL 那台服务器的 IO 压力也比较大。


所以这个原因也比较明显了:


由于每消费一条数据都要去查询一次数据库,MySQL 本身压力就比较大,加上数据量也很高所以导致这个 IO 响应较慢,导致整个任务处理的就比较慢了。


但还有一个原因也不能忽视;由于所有的业务线程在某个时间点都进入了死循环,根本没有执行完任务的机会,而后面的数据还在源源不断的进入,所以这个队列只会越堆越多!


这其实是一个老应用了,可能会有人问为什么之前没出现问题。


这是因为之前数据量都比较少,即使是并发写入也没有出现并发扩容形成环形链表的情况。这段时间业务量的暴增正好把这个隐藏的雷给揪出来了。所以还是得信墨菲他老人家的话。


总结


至此整个排查结束,而我们后续的调整措施大概如下:


  • HashSet 不是线程安全的,换为 ConcurrentHashMap同时把 value 写死一样可以达到 set 的效果。


  • 根据我们后面的监控,初始化 ConcurrentHashMap 的大小尽量大一些,避免频繁的扩容。


  • MySQL 中很多数据都已经不用了,进行冷热处理。尽量降低单表数据量。同时后期考虑分表。


  • 查数据那里调整为查缓存,提高查询效率。


  • 线程池的名称一定得取的有意义,不然是自己给自己增加难度。


  • 根据监控将线程池的队列大小调整为一个具体值,并且要有拒绝策略。


  • 升级到 JDK1.8


  • 再一个是报警邮件酌情考虑为电话通知😂。


HashMap 的死循环问题在网上层出不穷,没想到还真被我遇到了。现在要满足这个条件还是挺少见的,比如 1.8 以下的 JDK 这一条可能大多数人就碰不到,正好又证实了一次墨菲定律。


同时我会将文章更到这里,方便大家阅读和查询。


相关文章
|
1月前
|
安全
List并发线程安全问题
【10月更文挑战第21天】`List` 并发线程安全问题是多线程编程中一个非常重要的问题,需要我们认真对待和处理。只有通过不断地学习和实践,我们才能更好地掌握多线程编程的技巧和方法,提高程序的性能和稳定性。
190 59
|
7月前
并发编程之的HashSet和HashMap的详细解析
并发编程之的HashSet和HashMap的详细解析
46 0
|
7月前
|
安全 容器
线程安全的集合类(多线程环境下使用ArrayList、队列及哈希表)
线程安全的集合类(多线程环境下使用ArrayList、队列及哈希表)
|
安全 算法 Java
JDK 7 HashMap 并发死链
JDK 7 HashMap 并发死链
|
安全
集合类在并发情况下如何保证线程安全
在正常单线程的情况下不会出现问题,当多线程的时候,List会出现 java.util.ConcurrentModificationException 这种异常
102 0
|
监控 安全
记一次ArrayList使用不当引起的并发问题
小卷今天收到业务方反馈,调用接口有异常发生,而且随着流量增大,异常也增多了。小卷赶紧查看监控日志,发现ArrayIndexOutOfBoundsException数组越界异常变多了。于是开始进行排查。
218 0
记一次ArrayList使用不当引起的并发问题
|
算法 Java
都说 HashMap 是线程不安全的,到底体现在哪儿?
都说 HashMap 是线程不安全的,到底体现在哪儿?
118 0
都说 HashMap 是线程不安全的,到底体现在哪儿?
20. 你知道为什么HashMap是线程不安全的吗?下
20. 你知道为什么HashMap是线程不安全的吗?下
110 0
|
安全 开发者
JUC并发(并发的包)下的CopyOnWriteArrayList(线程安全的集合)
JUC并发(并发的包)下的CopyOnWriteArrayList(线程安全的集合)
138 0
JUC并发(并发的包)下的CopyOnWriteArrayList(线程安全的集合)
|
Java 容器
Java——多线程高并发系列之ArrayList、HashSet、HashMap集合线程不安全的解决方案
Java——多线程高并发系列之ArrayList、HashSet、HashMap集合线程不安全的解决方案
Java——多线程高并发系列之ArrayList、HashSet、HashMap集合线程不安全的解决方案