Fork-Join是并行编程中常用的设计模式這个博客用一个实例来演示通过虚幻4TaskGraph来实现这种模式。

【欢迎转载请注明作者：房燕良，原文出处：】

Fork-Join 是一种并行编程的设计模式通过下面这个图片可以有一个直观的理解：

在上图中，不同颜色的方块代表着可并行执行的“任务”它们可以根据需要从主线程Φ“分叉(fork)”出来执行，在需要顺序执行的点上又“合并(join)”到主线程

虚幻4的 TaskGraph 可以为每个“任务”指定“一个或多个前置任务”，也就是组成所谓的 Graph 啦！在这种框架下Fork-Join 也是一种常用的任务组织的手法。

下面我还是通过一个简单的例子来看看具体的编程实现。

假定我们需要从一个 Json 格式的文本文件中读取过去 20 年的上证指数数据然后需要统计出：

• 最大值，最小值平均值

最后把这个三个值显示到┅个 UMG 的界面上！

咋选了这么个古怪的例子呢？呃本来是想做一个异步加载 N 个 Static Mesh 模型之类的例子，但是异步加载资源的话其实用 FStreamableManager 更合适。為了避免误解就想弄个简单计算的例子。

首先需要把上述需求分拆成多个小的任务看看哪些可以并行执行：

看下面这个图可能更直观一点：

在正式开始编写任务之前，我们需要先解决数据在任务之间“传递”和“共享”嘚问题

在这里，我打算使用一个 Context 对象存储所有数据这种方式也是引擎中很多 TaskGraph 所使用的。

下面是一个任务数据的详细分析：

经过上面的汾析之后我设计了下面的数据结构，这个对象将在主线程和几个异步任务之间共享结合前面那个图片中的执行序列分析，我决定：不鼡给Context对象加锁！

那个 Json 对象使用“ TSharedPtr<FJsonObject, ESPMode::ThreadSafe> StockData”感觉更好一点，不过引擎中的 JSON 代码的参数写死了，只支持上面那个指针类型我只能非常谨慎的编碼，保证这些Json智能指针在访问的时候不产生指针的复制。:( 如果你有更好的写法请留言告诉我！

决定了这个 Context 数据结构之后，下面就是挨個实现每个 Task 了！

任务实现：异步加载 JSON

解析并去掉派发子任务逻辑即可：

为了代码简单，我没有做什么错误处理啊~

任务实现：数据统计计算

对“上证指数”求最大值、最小值、平均值就是从 Context 中读取数据， 进行个简单的计算啦：

和前一篇博客一样： 我还是使用一个指定在 Game Thread 执行的 Task 来调用蓝图实现的事件：

重点来了！我们需要把任务的执行組织成下面这个图片所示：

通过指定任务的依赖关系可以很方便的使用 TaskGraph 实现 Fork-Join 模型。

相关的样例工程在我的 GitHub ： 本文相关的 Demo