0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看威廉希尔官方网站 视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

基于OpenHarmony标准系统的C++公共基础类库案例:SafeQueue

福州市凌睿智捷电子有限公司 2024-08-30 12:41 次阅读

1、程序简介

该程序是基于OpenHarmonyC++公共基础类库的线程安全队列:SafeQueue。

线程安全队列,是在dequeue的基础上封装std::lock_guard,以此实现线程的相关操作。根据继承SafeQueueInner抽象类,并对dequeue的pop方法的重写,可以实现SafeStack和SafeQueue的相关方法。

本案例主要完成如下工作:

创建2个子线程,1个线程负责入队操作,1个线程负责出队操作

子线程入队操作,每1秒做1次入队操作,循环5次

子线程入队操作,每0.5秒做1次出队操作,循环5次

该案例已在凌蒙派-RK3568开发板验证过,如需要完整源代码,请参考:

https://gitee.com/Lockzhiner-Electronics/lockzhiner-rk3568-openharmony/tree/master/samples/a27_utils_safequeue

2、基础知识

C++公共基础类库为标准系统提供了一些常用的C++开发工具类,包括:

文件、路径、字符串相关操作的能力增强接口

读写锁、信号量、定时器、线程增强及线程池等接口

安全数据容器、数据序列化等接口

各子系统的错误码相关定义

2.1、添加C++公共基础类库依赖

修改需调用模块的BUILD.gn,在external_deps或deps中添加如下:

ohos_shared_library("xxxxx") { ... external_deps = [ ... # 动态库依赖(可选) "c_utils:utils", # 静态库依赖(可选) "c_utils:utilsbase", # Rust动态库依赖(可选) "c_utils:utils_rust", ] ...}

一般而言,我们只需要填写"c_utils:utils"即可。

2.2、SafeQueue头文件

C++公共基础类库的SafeQueue头文件在://commonlibrary/c_utils/base/include/safe_queue.h

可在源代码中添加如下:

#include

2.3、OHOS::SafeQueueInner接口说明

2.3.1、SafeQueueInner

构造函数。

SafeQueueInner();

2.3.2、~SafeQueueInner()

析构函数。

~SafeQueueInner();

2.3.3、Erase

移除某个元素。

void Erase(T& object);

参数说明:

参数名称类型参数说明
objectT需要移除的元素

2.3.4、Empty

队列判空。

bool Empty();

返回值说明:

类型返回值说明
booltrue表示成功,false表示失败

2.3.5、Clear

清空队列元素。

void Clear();

2.3.6、Size

获取队列的容量。

int Size();

返回值说明:

类型返回值说明
int返回队列的容量

2.3.7、Push

入队操作。

void Push(const T& pt);

参数说明:

参数名称类型参数说明
ptT需要入队的元素

2.3.8、DoPush

Push底层调用DoPush,需要重写。

virtual void DoPush(const T& pt) = 0;

参数说明:

参数名称类型参数说明
ptT需要入队的元素

2.3.9、Pop

出队操作。

bool Pop(T& pt);

参数说明:

参数名称类型参数说明
ptT需要出队的元素

返回值说明:

类型返回值说明
booltrue表示空,false表示非空

2.3.10、DoPop

出队操作。

virtual bool DoPop(T& pt) = 0;

参数说明:

参数名称类型参数说明
ptT需要出队的元素

返回值说明:

类型返回值说明
booltrue表示空,false表示非空

2.4、OHOS::SafeQueue接口说明

SafeQueue继承SafeQueueInner,实现DoPush()和DoPop()。

class SafeQueue : public SafeQueueInner

2.4.1、DoPush

入队操作。

void DoPush(const T& pt);

参数说明:

参数名称类型参数说明
ptT需要入队的元素

2.4.2、DoPop

出队操作。

bool DoPop(T& pt);

参数说明:

参数名称类型参数说明
ptT需要出队的元素

返回值说明:

类型返回值说明
booltrue表示空,false表示非空

3、程序解析

3.1、创建编译引导

在上一级目录BUILD.gn文件添加一行编译引导语句。

import("//build/ohos.gni")
group("samples") { deps = [ "a27_utils_safequeue:utils_safequeue", # 添加该行 ]}

"a27_utils_safequeue:utils_safequeue",该行语句表示引入 参与编译。

3.2、创建编译项目

创建a27_utils_safequeue目录,并添加如下文件:

a27_utils_safequeue├── utils_safequeue_sample.cppp # .cpp源代码├──BUILD.gn#GN文件

3.3、创建BUILD.gn

编辑BUILD.gn文件。

import("//build/ohos.gni")ohos_executable("utils_safequeue") { sources = [ "utils_safequeue_sample.cpp" ] include_dirs = [ "//commonlibrary/c_utils/base/include", "//commonlibrary/c_utils/base:utils", "//third_party/googletest:gtest_main", "//third_party/googletest/googletest/include" ] external_deps = [ "c_utils:utils" ] part_name = "product_rk3568" install_enable = true}

注意:

(1)BUILD.gn中所有的TAB键必须转化为空格,否则会报错。如果自己不知道如何规范化,可以:

# 安装gn工具sudo apt-get install ninja-buildsudo apt install generate-ninja# 规范化BUILD.gngn format BUILD.gn

3.4、创建源代码

3.4.1、创建SafeMap

#include // SafeQueue的头文件
// 定义队列变量static OHOS::SafeQueue m_safeQueue;

3.4.2、创建线程池并设置

int main(int argc, char **argv){ OHOS::ThreadPool threads("threads"); string str_name; ...... threads.SetMaxTaskNum(128); threads.Start(2); ......}

3.4.3、启动2个子线程,并等待结束

调用AddTask()添加子线程,并调用Stop()等待所有子进程结束。

// 开启子线程,使用Pushstr_name = "Thread_SafeQueue_Push";auto task_push = std::bind(funcSafeQueuePush, str_name);threads.AddTask(task_push);
// 开启子线程,使用Popstr_name = "Thread_SafeQueue_Pop";auto task_pop = std::bind(funcSafeQueuePop, str_name);threads.AddTask(task_pop);
// 设置结束,并等待结束threads.Stop();cout << "Threads Stop" << endl;

3.4.4、子线程入队操作

static void funcSafeQueuePush(const string &name){ for (int i = 0; i < 5; i++) { // 入队操作 cout << name << ", Push Start and i = " << i << endl; m_safeQueue.Push(i); cout << name << ", Push Successful and i = " << i << " and value = " << i << endl; // 睡眠1秒 cout << name << ", Sleep 1 sec" << endl; std::sleep_for(std::milliseconds(1000)); }}

3.4.5、子线程出队操作

static void funcSafeQueuePop(const string &name){ bool ret; int value; for (int i = 0; i < 5; i++) { // 出队操作 cout << name << ", Pop Start and i = " << i << endl; ret = m_safeQueue.Pop(value); cout << name << ", Pop Successful and i = " << i << " and ret = " << ret << " and value = " << value << endl; // 睡眠0.5秒 cout << name << ", Sleep 0.5 sec" << endl; std::sleep_for(std::milliseconds(500)); }
}

4、编译步骤

进入OpenHarmony编译环境,运行命令:

hb build -f

5、运行结果

# utils_safequeueThread_SafeQueue_Push, Push Start and i = 0Thread_SafeQueue_Push, Push Successful and i = 0 and value = 0Thread_SafeQueue_Push, Sleep 1 secThread_SafeQueue_Pop, Pop Start and i = 0Thread_SafeQueue_Pop, Pop Successful and i = 0 and ret = 1 and value = 0Thread_SafeQueue_Pop, Sleep 0.5 secThread_SafeQueue_Pop, Pop Start and i = 1Thread_SafeQueue_Pop, Pop Successful and i = 1 and ret = 0 and value = 0Thread_SafeQueue_Pop, Sleep 0.5 secThread_SafeQueue_Push, Push Start and i = 1Thread_SafeQueue_Push, Push Successful and i = 1 and value = 1Thread_SafeQueue_Push, Sleep 1 secThread_SafeQueue_Pop, Pop Start and i = 2Thread_SafeQueue_Pop, Pop Successful and i = 2 and ret = 1 and value = 1Thread_SafeQueue_Pop, Sleep 0.5 secThread_SafeQueue_Pop, Pop Start and i = 3Thread_SafeQueue_Pop, Pop Successful and i = 3 and ret = 0 and value = 1Thread_SafeQueue_Pop, Sleep 0.5 secThread_SafeQueue_Push, Push Start and i = 2Thread_SafeQueue_Push, Push Successful and i = 2 and value = 2Thread_SafeQueue_Push, Sleep 1 secThread_SafeQueue_Pop, Pop Start and i = 4Thread_SafeQueue_Pop, Pop Successful and i = 4 and ret = 1 and value = 2Thread_SafeQueue_Pop, Sleep 0.5 secThread_SafeQueue_Push, Push Start and i = 3Thread_SafeQueue_Push, Push Successful and i = 3 and value = 3Thread_SafeQueue_Push, Sleep 1 secThread_SafeQueue_Push, Push Start and i = 4Thread_SafeQueue_Push, Push Successful and i = 4 and value = 4Thread_SafeQueue_Push, Sleep 1 secThreads Stop#

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • Queue
    +关注

    关注

    0

    文章

    16

    浏览量

    7261
  • Safe
    +关注

    关注

    0

    文章

    5

    浏览量

    7241
  • OpenHarmony
    +关注

    关注

    25

    文章

    3716

    浏览量

    16268
收藏 人收藏

    评论

    相关推荐

    基于OpenHarmony标准系统C++公共基础案例:ThreadPoll

    1、程序简介 该程序是基于OpenHarmony标准系统C++公共基础的线程池处理:Thr
    发表于 08-12 11:42

    基于OpenHarmony标准系统C++公共基础案例:Semaphore

    1、程序简介 该程序是基于OpenHarmony标准系统C++公共基础的线程处理:Semp
    发表于 08-14 16:38

    基于OpenHarmony标准系统C++公共基础案例:rwlock

    /samples/a25_utils_rwlock 2、基础知识 C++公共基础标准系统提供了一些常用的
    发表于 08-20 09:37

    基于OpenHarmony标准系统C++公共基础案例:SafeMap

    基础标准系统提供了一些常用的C++开发工具,包括: 文件、路径、字符串相关操作的能力增强接口 读写锁、信号量、定时器、线程增强及线程
    发表于 08-20 12:00

    基于OpenHarmony标准系统C++公共基础案例:SafeQueue

    /a27_utils_safequeue 2、基础知识 C++公共基础标准系统提供了一些常
    发表于 08-21 10:56

    基于OpenHarmony标准系统C++公共基础案例:SafeStack

    /a28_utils_safestack 2、基础知识 C++公共基础标准系统提供了一些常用的C+
    发表于 08-21 14:51

    基于OpenHarmony标准系统C++公共基础案例:SafeBlockQueue

    /samples/a29_utils_safeblockqueue 2、基础知识 C++公共基础标准系统提供了一些常用的
    发表于 08-22 10:52

    OpenHarmony C++公共基础应用案例:Thread

    程在第5秒时,关闭子线程运行。 创建1个子线程,每隔1秒打印当前运行次数。 2、基础知识 C++公共基础标准系统提供了一些常用的
    发表于 11-22 11:50

    OpenHarmony C++公共基础应用案例:Thread

    1、程序简介该程序是基于OpenHarmonyC++公共基础的线程处理:Thread。该应用案例已在
    的头像 发表于 11-23 08:22 914次阅读
    <b class='flag-5'>OpenHarmony</b> <b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>应用案例:Thread

    OpenHarmony C++公共基础应用案例:HelloWorld

    1、程序简介该程序是基于OpenHarmonyC++公共基础的简单案例:HelloWorld。该应用案例已在
    的头像 发表于 11-23 08:22 695次阅读
    <b class='flag-5'>OpenHarmony</b> <b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>应用案例:HelloWorld

    OpenHarmony标准系统C++公共基础案例:HelloWorld

    1、程序简介该程序是基于凌蒙派OpenHarmony-v3.2.1标准系统C++公共基础的简
    的头像 发表于 08-13 08:23 515次阅读
    <b class='flag-5'>OpenHarmony</b><b class='flag-5'>标准系统</b><b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>案例:HelloWorld

    基于OpenHarmony标准系统C++公共基础案例:SafeBlockQueue

    1、程序简介该程序是基于OpenHarmonyC++公共基础的读写锁:SafeBlockQueue。线程安全阻塞队列SafeBlock
    的头像 发表于 08-30 12:41 298次阅读
    基于<b class='flag-5'>OpenHarmony</b><b class='flag-5'>标准系统</b>的<b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>案例:SafeBlockQueue

    基于OpenHarmony标准系统C++公共基础案例:SafeStack

    1、程序简介该程序是基于OpenHarmonyC++公共基础的线程安全队列:SafeQueue
    的头像 发表于 08-30 12:41 320次阅读
    基于<b class='flag-5'>OpenHarmony</b><b class='flag-5'>标准系统</b>的<b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>案例:SafeStack

    基于OpenHarmony标准系统C++公共基础案例:SafeMap

    1、程序简介该程序是基于OpenHarmonyC++公共基础的安全关联容器:SafeMap。Ope
    的头像 发表于 08-30 12:42 344次阅读
    基于<b class='flag-5'>OpenHarmony</b><b class='flag-5'>标准系统</b>的<b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>案例:SafeMap

    基于OpenHarmony标准系统C++公共基础案例:rwlock

    1、程序简介该程序是基于OpenHarmonyC++公共基础的读写锁:rwlock。本案例主要完成如下工作:创建3个读线程,每个读线程
    的头像 发表于 08-30 12:42 363次阅读
    基于<b class='flag-5'>OpenHarmony</b><b class='flag-5'>标准系统</b>的<b class='flag-5'>C++</b><b class='flag-5'>公共</b>基础<b class='flag-5'>类</b><b class='flag-5'>库</b>案例:rwlock