• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1# Function Flow Runtime任务伙伴(C++)
2
3<!--Kit: Function Flow Runtime Kit-->
4<!--Subsystem: Resourceschedule-->
5<!--Owner: @chuchihtung; @yanleo-->
6<!--Designer: @geoffrey_guo; @huangyouzhong-->
7<!--Tester: @lotsof; @sunxuhao-->
8<!--Adviser: @foryourself-->
9
10## 概述
11
12从API version 20开始，FFRT支持Job_Partner功能。在实际业务中，可能会遇到某一个线程（比如UI绘制线程）耗时很长，难以充分利用CPU多核能力的情况。此时，将原有线程的大任务拆分为多个小任务交给其他线程去执行是解决该问题的有效方法。但是，在实践中，会遇到两个问题：
13
14- 问题1：小任务中的部分片段受限于某些原因，必须执行在指定的线程上（比如访问JS虚拟机中的变量）。
15- 问题2：小任务会被拆分为多个小片段（可能由于问题1或者其他原因），单次执行时间可能在微秒级，而单次线程唤醒的开销在几十个微秒级，难以获得并发收益。
16
17为解决以上问题，Job Partner并发范式应运而生。
18
19![image](figures/ffrt_figure8.png)
20
21Job Partner并发范式中定义原先的线程为master线程，并支持动态管理partner线程（伙伴线程）。它有两个特性：
22
23- 特性1：针对问题1，支持partner线程在执行任务过程中暂停当前任务的执行，之后将任务发送到master线程执行，直到master线程执行完成之后在partner线程继续执行原有任务。
24- 特性2：针对问题2，利用批量小任务的特征，动态将多个小任务合并为更大的FFRT任务，以均摊单个小任务的调度开销。
25
26## 示例：某商城系统
27
28实现一个商城系统的节点并行化创建，要求节点创建的部分代码片段必须在JS线程中运行，其他片段可以在任意线程执行。
29
30以下是原有伪代码实现：
31
32```cpp
33namespace market_system {
34    // 批量创建节点，在js线程上被调用
35    void create_nodes(std::array<Node>& nodes)
36    {
37        for (int i = 0; i < nodes.size(); i++) {
38            code1(); // 可以在任意线程上执行的代码片段
39            code2(); // 必须在js线程上执行的代码片段
40            code3(); // 可以在任意线程上执行的代码片段
41        }
42    }
43};
44```
45
46使用Job Partner并行化后的伪代码如下：
47
48```cpp
49#include <array>
50#include <memory>
51#include "ffrt/ffrt.h" // 来自 OpenHarmony 第三方库 "@ppd/ffrt"
52
53namespace market_system {
54    // 批量创建节点，在js线程上被调用
55    void create_nodes(std::array<Node>& nodes)
56    {
57        constexpr uint64_t stack_size = 16 * 1024;
58        auto stack = std::make_unique<std::array<char, stack_size>[]>(nodes.size()); // 创建job_num个执行栈
59        auto partner = ffrt::job_partner<>::get_partner_of_this_thread(); // 获得当前js线程的伙伴
60        for (int i = 0; i < nodes.size(); i++) {
61            partner->submit([&] { // 每个节点的创建提交给partner
62                code1(); // 可以在任意线程上执行的代码片段
63                ffrt::job_partner<>::submit_to_master([&] { // 遇到必须在master线程执行的任务时发给主线程并同步等待
64                    code2(); // 必须在js线程上执行的代码片段
65                });
66                code3(); // 可以在任意线程上执行的代码片段
67            }, &stack[i], stack_size);
68        }
69        partner->wait(); // 等待所有节点创建完成
70    }
71};
72```
73
74## 接口说明
75
76上述样例中涉及的主要FFRT接口及其功能包括：
77
78| 名称                                                                                                                                | 描述               |
79| ----------------------------------------------------------------------------------------------------------------------------------- | ------------------ |
80| [job_partner](https://gitee.com/openharmony/resourceschedule_ffrt/blob/master/docs/ffrt-api-guideline-cpp.md#job_partner)     | 细粒度任务伙伴接口。 |
81
82> **说明：**
83>
84> - 如何使用FFRT C++ API详见：[FFRT C++接口三方库使用指导](ffrt-development-guideline.md#using-ffrt-c-api-1)。
85> - 使用FFRT C接口或C++接口时，都可以通过FFRT C++接口三方库简化头文件包含，即使用`#include "ffrt/ffrt.h"`头文件包含语句。
86
87## 约束限制
88
89- 适用Job Partner并发范式的场景应该是粒度较小且不会长时间阻塞线程的大批量任务。
90- 如果任务粒度较大（比如数百微秒以上），推荐使用FFRT更为通用的任务提交接口。
91- 如果任务不满足大批量的特征，使用Job Partner并发范式并不能显著降低调度开销。
92