PriorityForkJoinTask是为图计算定制的增强型任务类，通过拓扑层级、入度剩余数、关键路径标识动态生成优先级，并结合图感知老化与最小堆本地队列实现饥饿抑制。
PriorityForkJoinTask 不是标准 Java ForkJoin 框架内置类，而是工程中为图计算场景定制的增强型任务类型——它在基础 ForkJoinTask 上叠加了显式优先级语义与分治调度协同机制。其“规避任务饥饿”的能力，并非来自单一设计，而是优先级、分治结构、拓扑约束三者耦合形成的特异反馈闭环。
拓扑排序对任务调度的刚性约束
图计算中拓扑排序本质是依赖驱动的线性化过程：节点 v 的排序位置必须晚于所有入边前驱。若用普通 ForkJoin 并行化，易出现两类饥饿：
- 高入度节点（如中心枢纽）的子任务长期等待大量前置任务完成，自身被“卡住”
- 低优先级但关键路径上的节点，因全局优先级排序被延后，拖慢整图收敛
PriorityForkJoinTask 将拓扑层级（depth）、入度剩余数（remainingInDegree）、是否在关键路径（isCritical）等维度编码进优先级值，使调度器天然倾向先处理“阻塞面小、推进快、影响广”的子图片段。
优先级与分治粒度的动态绑定
它不把优先级静态绑定到整个任务，而是在 fork 阶段按子图特征重算：
- 对稀疏子图（边少、入度低），赋予更高调度优先级——快速释放下游依赖
- 对稠密子图（如强连通分量），自动降级并切分为更小粒度，避免单个高开销任务垄断线程池
- 每个子任务的 priority 字段实际是 topo_level × weight + urgency_score，随递归深度和依赖状态实时更新
饥饿抑制的双通道老化机制
传统老化仅对等待时间做线性提升，而 PriorityForkJoinTask 引入图感知老化：
- 结构老化：某节点连续 3 轮未能启动（因前置未就绪），其入度权重系数自动 ×1.5，下次计算 priority 时显著跃升
- 路径老化：若从源点到该节点的任意最长路径延迟超阈值，触发“关键路径加速标记”，绕过部分公平性检查直接插入高优先级队列
这种机制让真正受阻的低优先级节点，不是靠“等得久”翻身，而是靠“被图结构证明它卡住了关键流”获得调度权。
调度器与 ForkJoinPool 的协同适配
标准 ForkJoinPool 仅支持 FIFO 或栈式窃取，无法响应优先级。因此 PriorityForkJoinTask 必须配合定制工作窃取策略：
- 本地队列改用最小堆（按 priority 排序），确保 peek() 总是最高优待执行任务
- 窃取方不再随机选队列，而是扫描所有空闲 worker 的本地堆顶，挑出 priority 最高的那个任务窃取
- 当检测到某子图长时间无进展，主动触发“拓扑重平衡”：将卡住节点及其未完成前驱打包为新高优任务，注入全局高优队列
这使得饥饿不再是被动等待问题，而成为可检测、可定位、可干预的图结构异常信号。
