如何处理fork-join-queue的最终一致性？求指导替换缺陷实现

嘿各位大佬，我现在碰到个头疼的问题：我正试着替换掉一个有缺陷的fork-join-queue实现，这个缺陷版本是在一个近8年历史的视频33分37秒处介绍的。

虽然我知道这视频年代有点久，也非常乐意了解这个场景下更优的新实现方案，但目前我的优先级必须放在严格实现Brett在视频里讲的那个方案上。

可现在我的实现完全乱套了——原开发者的部分代码逻辑和Brett讲解的内容对不上，我越改越懵，根本没法推进下去。有没有过来人能给我梳理下关键点，或者提供一些具体的实现指引呀？

内容的提问来源于stack exchange，提问作者sripberger