Apache SkyWalking 中 CounterWindow 并发问题分析与修复
问题背景
在 Apache SkyWalking 的 OAP 服务器中,CounterWindow 类负责处理指标数据的窗口计算。该组件主要用于实现类似 increase('PT1M')
这样的函数调用,用于计算指标在指定时间窗口内的增量值。
问题现象
当多个实例同时上报自定义指标数据时,系统偶尔会抛出 NullPointerException
异常,错误信息显示在比较 Tuple2 对象时出现了空指针。更深入的分析发现,这是由于 PriorityQueue 在多线程环境下被并发修改导致的内部状态损坏。
根本原因分析
CounterWindow 类使用了两个 ConcurrentHashMap 来存储指标数据:
lastElementMap
存储最后一个元素windows
存储时间窗口内的数据队列
问题出在 windows
这个 ConcurrentHashMap 上。虽然 ConcurrentHashMap 本身是线程安全的,但它返回的 PriorityQueue 实例并不是线程安全的。当多个线程同时对同一个 PriorityQueue 进行操作时(如 offer、poll、peek 等),会导致队列内部状态不一致,最终引发各种异常。
技术细节
PriorityQueue 是一个基于优先级堆的无界队列,其内部实现依赖于数组和堆排序算法。在多线程环境下,如果不对其进行同步控制,可能会出现以下问题:
- 数组越界
- 堆结构破坏
- 元素丢失
- 返回错误的最小/最大值
在 SkyWalking 的场景中,当多个线程同时调用 increase()
方法处理同一个指标时,就会对同一个 PriorityQueue 进行并发修改,导致上述问题。
解决方案
最简单的修复方法是在操作 PriorityQueue 时添加同步锁。具体修改是在 increase()
方法中,使用 synchronized
关键字对 window 对象加锁:
public Tuple2<Long, Double> increase(String name, ImmutableMap<String, String> labels,
Double value, long windowSize, long now) {
ID id = new ID(name, labels);
Queue<Tuple2<Long, Double>> window = windows.computeIfAbsent(id, unused -> new PriorityQueue<>());
synchronized (window) {
// 所有对window的操作都在同步块内
window.offer(Tuple.of(now, value));
// ... 其余逻辑
}
}
这种解决方案虽然简单,但能有效解决问题。因为:
- 锁的粒度足够细,只锁定当前操作的队列
- 不会影响其他指标的并发处理
- 保持了原有的功能逻辑不变
影响范围
该问题主要影响使用 increase()
函数的自定义指标计算。当系统中有大量实例同时上报相同指标时,问题出现的概率会显著增加。一旦出现,会导致相关指标计算失败,直到服务重启。
最佳实践
对于类似场景的开发,建议:
- 明确区分容器本身的线程安全性和容器内容的线程安全性
- 对于复杂的集合操作,考虑是否需要额外的同步措施
- 在高并发场景下,优先考虑使用专门的并发集合类
- 进行充分的并发测试,特别是边界条件测试
总结
Apache SkyWalking 中的这个并发问题展示了在多线程环境下使用非线程安全集合的典型风险。通过添加适当的同步控制,可以有效地解决问题,同时保持系统的高性能特性。这也提醒我们在设计类似系统时,需要仔细考虑每个组件的线程安全特性。
HunyuanImage-3.0
HunyuanImage-3.0 统一多模态理解与生成,基于自回归框架,实现文本生成图像,性能媲美或超越领先闭源模型00ops-transformer
本项目是CANN提供的transformer类大模型算子库,实现网络在NPU上加速计算。C++045Hunyuan3D-Part
腾讯混元3D-Part00GitCode-文心大模型-智源研究院AI应用开发大赛
GitCode&文心大模型&智源研究院强强联合,发起的AI应用开发大赛;总奖池8W,单人最高可得价值3W奖励。快来参加吧~0288Hunyuan3D-Omni
腾讯混元3D-Omni:3D版ControlNet突破多模态控制,实现高精度3D资产生成00GOT-OCR-2.0-hf
阶跃星辰StepFun推出的GOT-OCR-2.0-hf是一款强大的多语言OCR开源模型,支持从普通文档到复杂场景的文字识别。它能精准处理表格、图表、数学公式、几何图形甚至乐谱等特殊内容,输出结果可通过第三方工具渲染成多种格式。模型支持1024×1024高分辨率输入,具备多页批量处理、动态分块识别和交互式区域选择等创新功能,用户可通过坐标或颜色指定识别区域。基于Apache 2.0协议开源,提供Hugging Face演示和完整代码,适用于学术研究到工业应用的广泛场景,为OCR领域带来突破性解决方案。00- HHowToCook程序员在家做饭方法指南。Programmer's guide about how to cook at home (Chinese only).Dockerfile09
- PpathwayPathway is an open framework for high-throughput and low-latency real-time data processing.Python00
热门内容推荐
最新内容推荐
项目优选









