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