带自动超时提升的优先级队列

发布: (2025年12月28日 GMT+8 12:19)
2 min read
原文: Dev.to

Source: Dev.to

cover

核心特性

有界并发

  • 可配置的工作池大小(默认:CPU 核心数 × 2)。
  • 超出工作池容量的任务会排队,以避免系统过载,同时最大化硬件利用率。

优先级队列与提升

  • 使用最小堆实现的五级优先级系统:Immediate > High > Retry > Normal > Low
  • 高优先级任务优先执行;同一优先级的任务按 FIFO(先进先出)顺序处理。
  • 等待时间过长的任务会自动提升到更高的优先级,以防止饥饿。
  • 提升阈值根据配置的超时时间计算。

错误重试

  • 当任务失败时,可自动进行重试。
  • 重试任务会以 Retry 优先级重新入队,该优先级位于 HighNormal 之间,提供延迟重试的效果。
Back to Blog

相关文章

阅读更多 »

高吞吐量 IoT 日志聚合器

封面图片:High-Throughput IoT Log Aggregator https://media2.dev.to/dynamic/image/width=1000,height=420,fit=cover,gravity=auto,format=auto/https%3A%2F%2Fde...