Function Flow Runtime并发队列(C)
============================

#### 概述

FFRT并发队列提供了设置任务优先级（Priority）和队列并发度的能力，使得队列中的任务能同时在多个线程上执行，获得更高的并行效果。

*   **队列并发度**：通过队列最大并发度设置，可以控制同一时刻同时执行的任务数量。这有助于避免任务并发过多对系统资源造成冲击，从而保证系统的稳定性和性能。
*   **任务优先级**：用户可以为每个任务设置优先级，不同的任务将严格按照优先级进行调度和执行。相同优先级的任务按照排队顺序执行，高优先级的任务将优先于低优先级的任务执行，确保关键任务能够及时处理。

#### 示例：银行服务系统

举例实现一个银行服务系统，每个客户向系统提交一个服务请求，可以区分普通用户和VIP用户，VIP用户的服务请求可以优先得到执行。银行系统中有2个窗口，可以并行取出用户提交的服务请求办理。

可以利用FFRT的并行队列范式做如下建模：

*   **排队逻辑**：并行队列。
*   **服务窗口**：并行队列的并发度，同时也对应FFRT Worker数量。
*   **用户等级**：并行队列任务优先级。

实现代码如下所示：

#include <cstdio>
#include <unistd.h>
#include "hilog/log.h"
#include "ffrt/ffrt.h" // 来自 OpenHarmony 第三方库 "@ppd/ffrt"

#undef LOG\_TAG
#define LOG\_TAG "ConcurrentTag"

const int SLEEP\_TIME = 100 \* 1000;
const int BANK\_CONCURRENCY = 2;

ffrt\_queue\_t CreateBankSystem(const char \*name, int concurrency)
{
    ffrt\_queue\_attr\_t queue\_attr;
    (void)ffrt\_queue\_attr\_init(&queue\_attr);
    ffrt\_queue\_attr\_set\_max\_concurrency(&queue\_attr, concurrency);

    // 创建一个并发队列
    ffrt\_queue\_t queue = ffrt\_queue\_create(ffrt\_queue\_concurrent, name, &queue\_attr);

    // 队列创建完后需要销毁队列属性
    ffrt\_queue\_attr\_destroy(&queue\_attr);
    if (!queue) {
        OH\_LOG\_INFO(LOG\_APP, "create queue failed");
        return NULL;
    }

    OH\_LOG\_INFO(LOG\_APP, "create bank system successfully");
    return queue;
}

void DestroyBankSystem(ffrt\_queue\_t queue\_handle)
{
    ffrt\_queue\_destroy(queue\_handle);
    OH\_LOG\_INFO(LOG\_APP, "destroy bank system successfully");
}

void BankBusiness(void \*arg)
{
    usleep(SLEEP\_TIME);
    const char \*data = (const char \*)arg;
    OH\_LOG\_INFO(LOG\_APP, "saving or withdraw for %{public}s", data);
}

// 封装提交队列任务函数
ffrt\_task\_handle\_t CommitRequest(ffrt\_queue\_t bank, void (\*func)(void \*), const char \*name,
    ffrt\_queue\_priority\_t level, int delay)
{
    ffrt\_task\_attr\_t task\_attr;
    (void)ffrt\_task\_attr\_init(&task\_attr);
    ffrt\_task\_attr\_set\_name(&task\_attr, name);
    ffrt\_task\_attr\_set\_queue\_priority(&task\_attr, level);
    ffrt\_task\_attr\_set\_delay(&task\_attr, delay);

    return ffrt\_queue\_submit\_h\_f(bank, func, (void\*)name, &task\_attr);
}

// 封装取消队列任务函数
int CancelRequest(ffrt\_task\_handle\_t request)
{
    return ffrt\_queue\_cancel(request);
}

// 封装等待队列任务函数
void WaitForRequest(ffrt\_task\_handle\_t task)
{
    ffrt\_queue\_wait(task);
}

int ConcurrentQueueCExec()
{
    ffrt\_queue\_t bank = CreateBankSystem("Bank", BANK\_CONCURRENCY);
    if (!bank) {
        printf("create bank system failed\\n");
        OH\_LOG\_INFO(LOG\_APP, "create bank system failed");
        return -1;
    }

    ffrt\_task\_handle\_t task1 = CommitRequest(bank, BankBusiness, "customer1", ffrt\_queue\_priority\_low, 0);
    ffrt\_task\_handle\_t task2 = CommitRequest(bank, BankBusiness, "customer2", ffrt\_queue\_priority\_low, 0);
    // VIP享受更优先的服务
    ffrt\_task\_handle\_t task3 = CommitRequest(bank, BankBusiness, "customer3 VIP", ffrt\_queue\_priority\_high, 0);
    ffrt\_task\_handle\_t task4 = CommitRequest(bank, BankBusiness, "customer4", ffrt\_queue\_priority\_low, 0);
    ffrt\_task\_handle\_t task5 = CommitRequest(bank, BankBusiness, "customer5", ffrt\_queue\_priority\_low, 0);

    // 取消客户4的服务
    CancelRequest(task4);

    // 等待所有的客户服务完成
    WaitForRequest(task5);
    DestroyBankSystem(bank);

    ffrt\_task\_handle\_destroy(task1);
    ffrt\_task\_handle\_destroy(task2);
    ffrt\_task\_handle\_destroy(task3);
    ffrt\_task\_handle\_destroy(task4);
    ffrt\_task\_handle\_destroy(task5);
    return 0;
}

![](https://contentcenter-vali-drcn.dbankcdn.cn/pvt_2/DeveloperAlliance_scene_100_1/bb/v3/46pstRI4Q9SzT7oN94Tcew/note_3.0-zh-cn.png?HW-CC-KV=V1&HW-CC-Date=20260709T132447Z&HW-CC-Expire=86400&HW-CC-Sign=9C655A0E4F47598D38ACD07175C2A397B8E9DE8530891A3C4EB9E8D9B329065F)

ffrt\_queue\_submit\_h\_f接口可以接收裸函数指针任务作为参数，如果任务存在前后处理可以参见[ffrt\_alloc\_auto\_managed\_function\_storage\_base](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_alloc_auto_managed_function_storage_base)函数查看如何构造任务结构体。

#### 接口说明

上述样例中涉及到主要的FFRT的接口包括：

| 名称 | 描述 |
| :-- | :-- |
| [ffrt\_queue\_create](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_queue_t) | 创建队列。 |
| [ffrt\_queue\_destroy](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_queue_t) | 销毁队列。 |
| [ffrt\_task\_attr\_set\_queue\_priority](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_task_attr_t) | 设置队列任务优先级。 |
| [ffrt\_queue\_attr\_set\_max\_concurrency](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_queue_attr_t) | 设置并发队列的并发度。 |
| [ffrt\_queue\_submit\_h\_f](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-api-guideline-c#ffrt_queue_t) | 
向队列提交一个任务。

**说明**：从API version 20开始，支持该接口。

 |

![](https://contentcenter-vali-drcn.dbankcdn.cn/pvt_2/DeveloperAlliance_scene_100_1/16/v3/ftSha-h3R8yUwm5VicJi-w/note_3.0-zh-cn.png?HW-CC-KV=V1&HW-CC-Date=20260709T132447Z&HW-CC-Expire=86400&HW-CC-Sign=EC616902613C425FF3A0F38C3BC71CE4D11B1189199C8D73B0D2801F6CC48E3C)

*   如何使用FFRT C++ API详见：[FFRT C++接口三方库使用指导](https://developer.huawei.com/consumer/cn/doc/harmonyos-guides/ffrt-development-guideline#using-ffrt-c-api-1)。
*   使用FFRT C接口或C++接口时，都可以通过FFRT C++接口三方库简化头文件包含，即使用#include "ffrt/ffrt.h"头文件包含语句。

#### 约束限制

1.  ffrt\_queue\_attr\_t必须先调用ffrt\_queue\_attr\_init初始化后再设置/获取属性，不再使用后需要显式调用ffrt\_queue\_attr\_destroy释放资源。
2.  ffrt\_queue\_t必须在进程退出前显式调用ffrt\_queue\_destroy释放资源。
3.  并发队列最大并发度建议控制在合理范围内，配置过大超过Worker线程数没有意义，配置过小可能导致系统资源利用率不足。