• 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
12FFRT并发队列提供了设置任务优先级（Priority）和队列并发度的能力，使得队列中的任务能同时在多个线程上执行，获得更高的并行效果。
13
14- **队列并发度**：通过队列最大并发度设置，可以控制同一时刻同时执行的任务数量。这有助于避免任务并发过多对系统资源造成冲击，从而保证系统的稳定性和性能。
15- **任务优先级**：用户可以为每个任务设置优先级，不同的任务将严格按照优先级进行调度和执行。相同优先级的任务按照排队顺序执行，高优先级的任务将优先于低优先级的任务执行，确保关键任务能够及时处理。
16
17## 示例：银行服务系统
18
19举例实现一个银行服务系统，每个客户向系统提交一个服务请求，可以区分普通用户和VIP用户，VIP用户的服务请求可以优先得到执行。
20银行系统中有2个窗口，可以并行取出用户提交的服务请求办理。可以利用FFRT的并行队列范式做如下建模：
21
22- **排队逻辑**：并行队列。
23- **服务窗口**：并行队列的并发度，同时也对应FFRT Worker数量。
24- **用户等级**：并行队列任务优先级。
25
26实现代码如下所示：
27
28```cpp
29#include <iostream>
30#include <unistd.h>
31#include "ffrt/ffrt.h" // 来自 OpenHarmony 第三方库 "@ppd/ffrt"
32
33class BankQueueSystem {
34private:
35    std::unique_ptr<ffrt::queue> queue_;
36
37public:
38    BankQueueSystem(const char *name, int concurrency)
39    {
40        queue_ = std::make_unique<ffrt::queue>(
41            ffrt::queue_concurrent, name, ffrt::queue_attr().max_concurrency(concurrency));
42        std::cout << "bank system has been initialized" << std::endl;
43    }
44
45    ~BankQueueSystem()
46    {
47        queue_ = nullptr;
48        std::cout << "bank system has been destroyed" << std::endl;
49    }
50
51    // 开始排队，即提交队列任务
52    ffrt::task_handle Enter(const std::function<void()>& func, const char *name, ffrt_queue_priority_t level, int delay)
53    {
54        return queue_->submit_h(func, ffrt::task_attr().name(name).priority(level).delay(delay));
55    }
56
57    // 退出排队，即取消队列任务
58    int Exit(const ffrt::task_handle &t)
59    {
60        return queue_->cancel(t);
61    }
62
63    // 等待排队，即等待队列任务
64    void Wait(const ffrt::task_handle& handle)
65    {
66        queue_->wait(handle);
67    }
68};
69
70void BankBusiness()
71{
72    usleep(100 * 1000);
73    std::cout << "saving or withdraw ordinary customer" << std::endl;
74}
75
76void BankBusinessVIP()
77{
78    usleep(100 * 1000);
79    std::cout << "saving or withdraw VIP" << std::endl;
80}
81
82int main()
83{
84    BankQueueSystem bankQueue("Bank", 2);
85
86    auto task1 = bankQueue.Enter(BankBusiness, "customer1", ffrt_queue_priority_low, 0);
87    auto task2 = bankQueue.Enter(BankBusiness, "customer2", ffrt_queue_priority_low, 0);
88    // VIP享受更优先的服务
89    auto task3 = bankQueue.Enter(BankBusinessVIP, "customer3 vip", ffrt_queue_priority_high, 0);
90    auto task4 = bankQueue.Enter(BankBusiness, "customer4", ffrt_queue_priority_low, 0);
91    auto task5 = bankQueue.Enter(BankBusiness, "customer5", ffrt_queue_priority_low, 0);
92
93    // 取消客户4的服务
94    bankQueue.Exit(task4);
95
96    // 等待所有的客户服务完成
97    bankQueue.Wait(task5);
98    return 0;
99}
100```
101
102## 接口说明
103
104上述样例中涉及到主要的FFRT的接口包括：
105
106| 名称                                                                                                                          | 描述         |
107| ----------------------------------------------------------------------------------------------------------------------------- | ------------ |
108| class [task_attr](https://gitee.com/openharmony/resourceschedule_ffrt/blob/master/docs/ffrt-api-guideline-cpp.md#task_attr)   | 任务属性类。 |
109| class [queue_attr](https://gitee.com/openharmony/resourceschedule_ffrt/blob/master/docs/ffrt-api-guideline-cpp.md#queue_attr) | 队列属性类。 |
110| class [queue](https://gitee.com/openharmony/resourceschedule_ffrt/blob/master/docs/ffrt-api-guideline-cpp.md#queue)           | 队列类。     |
111
112> **说明：**
113>
114> - 如何使用FFRT C++ API详见：[FFRT C++接口三方库使用指导](ffrt-development-guideline.md#using-ffrt-c-api-1)。
115> - 使用FFRT C接口或C++接口时，都可以通过FFRT C++接口三方库简化头文件包含，即使用`#include "ffrt/ffrt.h"`头文件包含语句。
116
117## 约束限制
118
1191. 并发队列最大并发度建议控制在合理范围内，配置过大超过Worker线程数没有意义，配置过小可能导致系统资源利用率不足。
120