• 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 <string>
24#include <ffrt.h>
25
26class BankQueueSystem {
27private:
28    std::unique_ptr<ffrt::queue> queue_;
29
30public:
31    BankQueueSystem(const char *name, int concurrency)
32    {
33        queue_ = std::make_unique<ffrt::queue>(queue_concurrent, name, queue_attr().max_concurrency(concurrency));
34        std::cout << "bank system has been initailized" << std::endl;
35    }
36
37    ~BankQueueSystem()
38    {
39        queue_ = nullptr;
40        std::cout << "bank system has been destoryed" << std::endl;
41    }
42
43    // 开始排队，即提交队列任务
44    task_handle Enter(const std::function<void()>& func, char *name, ffrt_queue_priority_t level, int delay)
45    {
46        return queue_->submit_h(func, ffrt::task_attr().name(name).priority(level).delay(delay));
47    }
48
49    // 退出排队，即取消队列任务
50    int Exit(const task_handle &t)
51    {
52        return queue_->cancel(t);
53    }
54
55    int GetQueueSize()
56    {
57        return queue_->get_task_cnt();
58    }
59
60    // 等待排队，即等待队列任务
61    void Wait(const task_handle& handle)
62    {
63        queue_->wait(handle);
64    }
65};
66
67void BankBusiness()
68{
69    usleep(100 * 1000);
70    std::cout << "saving or withdraw ordinary customer" << std::endl;
71}
72
73void BankBusinessVIP()
74{
75    usleep(100 * 1000);
76    std::cout << "saving or withdraw VIP" << std::endl;
77}
78
79int main() {
80    BankQueueSystem bankQueue("Bank", 2);
81
82    bankQueue.Enter(BankBusiness, "customer1", ffrt_queue_priority_low, 0);
83    bankQueue.Enter(BankBusiness, "customer2", ffrt_queue_priority_low, 0);
84    bankQueue.Enter(BankBusiness, "customer3", ffrt_queue_priority_low, 0);
85    bankQueue.Enter(BankBusiness, "customer4", ffrt_queue_priority_low, 0);
86
87    // VIP享受更优先的服务
88    bankQueue.Enter(BankBusinessVIP, "vip", ffrt_queue_priority_high, 0);
89
90    task_handle handle = bankQueue.Enter(BankBusiness, "customer5", ffrt_queue_priority_low, 0);
91    task_handle handleLast = bankQueue.Enter(BankBusiness, "customer6", ffrt_queue_priority_low, 0);
92
93    // 取消客户5的服务
94    bankQueue.Exit(handle);
95
96    std::cout << "bank current serving for " << bankQueue.GetQueueSize() << " customers" << std::endl;
97
98    // 等待所有的客户服务完成
99    bankQueue.Wait(handleLast);
100    return 0;
101}
102```
103
104## 接口说明
105
106上述样例中涉及到主要的FFRT的接口包括：
107
108| 名称                                                     | 描述         |
109| -------------------------------------------------------- | ------------ |
110| class [task_attr](ffrt-api-guideline-cpp.md#task_attr)   | 任务属性类。 |
111| class [queue_attr](ffrt-api-guideline-cpp.md#queue_attr) | 队列属性类。 |
112| class [queue](ffrt-api-guideline-cpp.md#queue)           | 队列类。     |
113
114> **说明：**
115>
116> 如何使用FFRT C++ API详见：[C++接口使用指导](ffrt-development-guideline.md#using-ffrt-c-api-1)
117
118## 约束限制
119
1201. 并发队列最大并发度建议控制在合理范围内，配置过大超过Worker线程数没有意义，配置过小可能导致系统资源利用率不足。
121