带自动超时提升的优先级队列
发布: (2025年12月28日 GMT+8 12:19)
2 min read
原文: Dev.to
Source: Dev.to
核心特性
有界并发
- 可配置的工作池大小(默认:CPU 核心数 × 2)。
- 超出工作池容量的任务会排队,以避免系统过载,同时最大化硬件利用率。
优先级队列与提升
- 使用最小堆实现的五级优先级系统:Immediate > High > Retry > Normal > Low。
- 高优先级任务优先执行;同一优先级的任务按 FIFO(先进先出)顺序处理。
- 等待时间过长的任务会自动提升到更高的优先级,以防止饥饿。
- 提升阈值根据配置的超时时间计算。
错误重试
- 当任务失败时,可自动进行重试。
- 重试任务会以
Retry优先级重新入队,该优先级位于High与Normal之间,提供延迟重试的效果。