在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

基于OpenHarmony標準系統的C++公共基礎類庫案例:SafeBlockQueue

福州市凌睿智捷電子有限公司 ? 2024-08-30 12:41 ? 次閱讀

1、程序簡介

該程序是基于OpenHarmonyC++公共基礎類庫的讀寫鎖:SafeBlockQueue。

線程安全阻塞隊列SafeBlockQueue類,提供阻塞和非阻塞版的入隊入隊和出隊接口,并提供可最追蹤任務完成狀態的的SafeBlockQueueTracking類。

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

(1)使用SafeBlockQueue接口的案例

判斷命令行是否使用阻塞,還是非阻塞;

創建子線程生產者,使用阻塞/非阻塞方式,入隊操作;

創建子線程消費者,使用阻塞/非阻塞方式,出隊操作;

主線程等待所有子線程結束

(2)使用SafeBlockQueueTracking接口的案例

判斷命令行是否使用阻塞,還是非阻塞;

創建子線程生產者,使用阻塞/非阻塞方式,入隊操作;

創建子線程消費者,使用阻塞/非阻塞方式,出隊操作;

主線程等待所有子線程結束

該案例已在凌蒙派-RK3568開發板驗證過,如需要完整源代碼,請參考:

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

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、SafeBlockQueue頭文件

C++公共基礎類庫的SafeBlockQueue頭文件在://commonlibrary/c_utils/base/include/safe_block_queue.h

可在源代碼中添加如下:

#include

2.3、OHOS::SafeBlockQueue接口說明

2.3.1、SafeBlockQueue

構造函數。

SafeBlockQueue(int capacity)

參數說明:

參數名稱類型參數說明
capacityintSafeBlockQueue的容量,即能存儲多少個單元

2.3.2、~SafeBlockQueue

析構函數。

~SafeBlockQueue();

2.3.3、Push

入隊操作(阻塞版)。

void virtual Push(T const& elem);

2.3.4、PushNoWait

入隊操作(非阻塞版)。

bool virtual PushNoWait(T const& elem);

返回值說明:

類型返回值說明
booltrue表示成功,false表示失敗

2.3.5、Pop

出隊操作(阻塞版)。

T Pop();

返回值說明:

類型返回值說明
T出隊的單元

2.3.6、PopNotWait

出隊操作(非阻塞版)。

bool PopNotWait(T& outtask);

參數說明:

參數名稱類型參數說明
outtaskT出隊的單元

返回值說明:

類型返回值說明
booltrue表示成功,false表示失敗

2.3.7、Size

獲取隊列容量。

unsigned int Size();

返回值說明:

類型返回值說明
unsigned int返回隊列的容量

2.3.8、IsEmpty

隊列判空。

bool IsEmpty;

返回值說明:

類型返回值說明
booltrue表示成功,false表示失敗

2.3.9、IsFull

判斷map是否為滿。

bool IsFull();

返回值說明:

類型返回值說明
booltrue表示空,false表示非空

2.4、OHOS::SafeBlockQueueTracking接口說明

2.4.1、SafeBlockQueue

構造函數。

SafeBlockQueue(int capacity)

參數說明:

參數名稱類型參數說明
capacityintSafeBlockQueue的容量,即能存儲多少個單元

2.4.2、~SafeBlockQueue

析構函數。

~SafeBlockQueue();

2.4.3、Push

入隊操作(阻塞版)。

void virtual Push(T const& elem);

2.4.4、PushNoWait

入隊操作(非阻塞版)。

bool virtual PushNoWait(T const& elem);

返回值說明:

類型返回值說明
booltrue表示成功,false表示失敗

3、程序解析

3.1、創建編譯引導

在上一級目錄BUILD.gn文件添加一行編譯引導語句。

import("http://build/ohos.gni")
group("samples") { deps = [ "a29_utils_safeblockqueue:utils_safeblockqueue", # 添加該行 ]}

"a29_utils_safeblockqueue:utils_safeblockqueue",該行語句表示引入 參與編譯。

3.2、創建編譯項目

創建a29_utils_safeblockqueue目錄,并添加如下文件:

a29_utils_safeblockqueue├── utils_safeblockqueue_sample.cpp # .cpp源代碼├── utils_safeblockqueuetracking_sample.cpp # .cpp源代碼├── BUILD.gn # GN文件

3.3、創建BUILD.gn

編輯BUILD.gn文件。

import("http://build/ohos.gni")
ohos_executable("utils_safeblockqueue_test") { sources = [ "utils_safeblockqueue_sample.cpp" ] include_dirs = [ "http://commonlibrary/c_utils/base/include", "http://commonlibrary/c_utils/base:utils", "http://third_party/googletest:gtest_main", "http://third_party/googletest/googletest/include" ] external_deps = [ "c_utils:utils" ] part_name = "product_rk3568" install_enable = true}
ohos_executable("utils_safeblockqueue_tracking") { sources = [ "utils_safeblockqueuetracking_sample.cpp" ] include_dirs = [ "http://commonlibrary/c_utils/base/include", "http://commonlibrary/c_utils/base:utils", "http://third_party/googletest:gtest_main", "http://third_party/googletest/googletest/include" ] external_deps = [ "c_utils:utils" ] part_name = "product_rk3568" install_enable = true}
group("utils_safeblockqueue") { deps = [ ":utils_safeblockqueue_test", # 構建SafeBlockQueue案例 ":utils_safeblockqueue_tracking", # 構建SafeBlockQueueTracking案例 ]}

注意:

(1)BUILD.gn中所有的TAB鍵必須轉化為空格,否則會報錯。如果自己不知道如何規范化,可以:

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

3.4、創建SafeBlockQueue案例源代碼

3.4.1、創建SafeBlockQueue變量

#include // SafeBlockQueue的頭文件
// 定義常量const int SIZE = 5;// 定義SafeBlockQueue變量OHOS::SafeBlockQueue m_safeBlockQueue(SIZE);

3.4.2、獲知運行阻塞/非阻塞方式

命令有1個參數,分別是:

wait:使用阻塞方式的SafeBlockQueue;

nowait:使用非阻塞方式的SafeBlockQueue;

int main(int argc, char **argv){ bool enable_wait = true; ...... // 獲取命令行參數 if (argc != 2) { cout << "Usage: " << argv[0] << " " << STRING_WAIT << "/" << STRING_NOWAIT << endl; return -1; } if (strncmp(argv[1], STRING_WAIT, sizeof(STRING_WAIT)) == 0) { enable_wait = true; } else if (strncmp(argv[1], STRING_NOWAIT, sizeof(STRING_NOWAIT)) == 0) { enable_wait = false; } else { cout << "Usage: " << argv[0] << " " << STRING_WAIT << "/" << STRING_NOWAIT << endl; return -1; }}

3.4.3、創建線程池并設置子線程數量

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

3.4.4、啟動2個子線程,并等待結束

調用AddTask()添加子線程,并調用Stop()等待所有子進程結束。

// 創建生產者線程cout << get_curtime() << ", " << __func__ << ": task_product start" << endl;auto task_product = (enable_wait) ? (std::bind(product_wait, str_name)) : (std::bind(product_nowait, str_name));threads.AddTask(task_product);
// 等待SIZE秒,將SafeBlockQueue容器填滿cout << get_curtime() << ", " << __func__ << ": sleep " << SIZE << " sec" << endl;std::sleep_for(std::milliseconds(1000 * SIZE));
// 創建消費者線程cout << get_curtime() << ", " << __func__ << ": consume start" << endl; auto task_consumer = (enable_wait) ? (std::bind(consume_wait, str_name)) : (std::bind(consume_nowait, str_name));threads.AddTask(task_consumer);
threads.Stop();cout << get_curtime() << ", " << __func__ << ": Queue Wait End" << endl;

3.4.5、子線程生產者,使用阻塞方式

static void product_wait(const string &name){ for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Push Start, i = " << i << endl; // 使用阻塞方式的SafeBlockQueue m_safeBlockQueue.Push(i); cout << get_curtime() << ", " << __func__ << ": Push Success, i = " << i << endl; // 等待1秒 cout << get_curtime() << ", " << __func__ << ": Sleep 1 sec " << endl; std::sleep_for(std::milliseconds(1000)); }}

3.4.6、子線程消費者,使用阻塞方式

static void consume_wait(const string &name){ for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Pop Start, i = " << i << endl; // 使用阻塞方式的SafeBlockQueue int value = m_safeBlockQueue.Pop(); cout << get_curtime() << ", " << __func__ << ": Pop Success, i = " << i << ", value = " << value << endl; // 等待0.5秒 cout << get_curtime() << ", " << __func__ << ": Sleep 0.5 sec " << endl; std::sleep_for(std::milliseconds(500)); }}

3.4.7、子線程生產者,使用非阻塞方式

static void product_nowait(const string &name){ bool ret; for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Push Start, i = " << i << endl; // 使用非阻塞方式的SafeBlockQueue ret = m_safeBlockQueue.PushNoWait(i); cout << get_curtime() << ", " << __func__ << ": Push ret = " << ret << ", i = " << i << endl; // 等待1秒 cout << get_curtime() << ", " << __func__ << ": Sleep 1 sec " << endl; std::sleep_for(std::milliseconds(1000)); }}

3.4.8、子線程消費者,使用非阻塞方式

static void consume_nowait(const string &name){ for (int i = 0; i < (SIZE * 2); i++) { // 等待有新數據 int value = 0; // 使用非阻塞方式的SafeBlockQueue bool ret = m_safeBlockQueue.PopNotWait(value); cout << get_curtime() << ", " << __func__ << ": PopNotWait ret = " << ret << ", value = " << value << endl; // 等待500毫秒 std::sleep_for(std::milliseconds(500)); }}

3.5、創建SafeBlockQueueTracking案例源代碼

3.5.1、創建SafeBlockQueueTracking變量

#include // SafeBlockQueue的頭文件
// 定義常量const int SIZE = 5;// 定義SafeBlockQueue變量OHOS::SafeBlockQueueTracking m_safeBlockQueueTracking(SIZE);

3.5.2、獲知運行阻塞/非阻塞方式

命令有1個參數,分別是:

wait:使用阻塞方式的SafeBlockQueue;

nowait:使用非阻塞方式的SafeBlockQueue;

int main(int argc, char **argv){ bool enable_wait = true; ...... // 獲取命令行參數 if (argc != 2) { cout << "Usage: " << argv[0] << " " << STRING_WAIT << "/" << STRING_NOWAIT << endl; return -1; } if (strncmp(argv[1], STRING_WAIT, sizeof(STRING_WAIT)) == 0) { enable_wait = true; } else if (strncmp(argv[1], STRING_NOWAIT, sizeof(STRING_NOWAIT)) == 0) { enable_wait = false; } else { cout << "Usage: " << argv[0] << " " << STRING_WAIT << "/" << STRING_NOWAIT << endl; return -1; }}

3.5.3、創建線程池并設置子線程數量

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

3.5.4、啟動2個子線程,并等待結束

調用AddTask()添加子線程,并調用Stop()等待所有子進程結束。

// 創建生產者線程cout << get_curtime() << ", " << __func__ << ": task_product start" << endl;auto task_product = (enable_wait) ? (std::bind(product_wait, str_name)) : (std::bind(product_nowait, str_name));threads.AddTask(task_product);
// 等待SIZE秒,將SafeBlockQueue容器填滿cout << get_curtime() << ", " << __func__ << ": sleep " << SIZE << " sec" << endl;std::sleep_for(std::milliseconds(1000 * SIZE));
// 創建消費者線程cout << get_curtime() << ", " << __func__ << ": consume start" << endl; auto task_consumer = (enable_wait) ? (std::bind(consume_wait, str_name)) : (std::bind(consume_nowait, str_name));threads.AddTask(task_consumer);
threads.Stop();cout<

3.5.5、子線程生產者,使用阻塞方式

static void product_wait(const string &name){ for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Push Start, i = " << i << endl; // 使用阻塞方式的SafeBlockQueueTracking m_safeBlockQueueTracking.Push(i); cout << get_curtime() << ", " << __func__ << ": Push Success, i = " << i << endl; // 等待1秒 cout << get_curtime() << ", " << __func__ << ": Sleep 1 sec " << endl; std::sleep_for(std::milliseconds(1000)); }}

3.5.6、子線程消費者,使用阻塞方式

static void consume_wait(const string &name){ for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Pop Start, i = " << i << endl; // 使用阻塞方式的SafeBlockQueueTracking int value = m_safeBlockQueueTracking.Pop(); cout << get_curtime() << ", " << __func__ << ": Pop Success, i = " << i << ", value = " << value << endl; m_safeBlockQueueTracking.OneTaskDone(); cout << get_curtime() << ", " << __func__ << ": Push OneTaskDone successful" << endl; // 等待0.5秒 cout << get_curtime() << ", " << __func__ << ": Sleep 0.5 sec " << endl; std::sleep_for(std::milliseconds(500)); }
}

3.5.7、子線程生產者,使用非阻塞方式

static void product_nowait(const string &name){ bool ret; for (int i = 0; i < (2 * SIZE); i++) { cout << get_curtime() << ", " << __func__ << ": Push Start, i = " << i << endl; // 使用非阻塞方式的SafeBlockQueueTracking ret = m_safeBlockQueueTracking.PushNoWait(i); cout << get_curtime() << ", " << __func__ << ": Push ret = " << ret << ", i = " << i << endl; if (ret == true) { m_safeBlockQueueTracking.OneTaskDone(); cout << get_curtime() << ", " << __func__ << ": Push OneTaskDone successful" << endl; } // 等待1秒 cout << get_curtime() << ", " << __func__ << ": Sleep 1 sec " << endl; std::sleep_for(std::milliseconds(1000)); }}

3.5.8、子線程消費者,使用非阻塞方式

static void consume_nowait(const string &name){ for (int i = 0; i < (SIZE * 2); i++) { // 等待有新數據 int value = 0; // 使用非阻塞方式的SafeBlockQueueTracking bool ret = m_safeBlockQueueTracking.PopNotWait(value); cout << get_curtime() << ", " << __func__ << ": PopNotWait ret = " << ret << ", value = " << value << endl; // 等待500毫秒 std::sleep_for(std::milliseconds(500)); }
}

4、編譯步驟

進入OpenHarmony編譯環境,運行命令:

hb build -f

5、運行結果

#

聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • Queue
    +關注

    關注

    0

    文章

    16

    瀏覽量

    7355
  • 系統
    +關注

    關注

    1

    文章

    1024

    瀏覽量

    21616
  • OpenHarmony
    +關注

    關注

    26

    文章

    3791

    瀏覽量

    17633
收藏 人收藏

    評論

    相關推薦

    基于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++公共基礎案例:SafeQueue

    /a27_utils_safequeue 2、基礎知識 C++公共基礎標準系統提供了一些常用的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

    1、程序簡介該程序是基于OpenHarmonyC++公共基礎的線程處理:Thread。該應用案例已在
    的頭像 發表于 11-23 08:22 ?1111次閱讀
    <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 ?842次閱讀
    <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 ?688次閱讀
    <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++公共基礎案例:SafeStack

    1、程序簡介該程序是基于OpenHarmonyC++公共基礎的線程安全隊列:SafeQueue。線程安全隊列,是在dequeue的基礎
    的頭像 發表于 08-30 12:41 ?510次閱讀
    基于<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++公共基礎案例:SafeQueue

    1、程序簡介該程序是基于OpenHarmonyC++公共基礎的線程安全隊列:SafeQueue。線程安全隊列,是在dequeue的基礎
    的頭像 發表于 08-30 12:41 ?498次閱讀
    基于<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>案例:SafeQueue

    基于OpenHarmony標準系統C++公共基礎案例:SafeMap

    1、程序簡介該程序是基于OpenHarmonyC++公共基礎的安全關聯容器:SafeMap。Ope
    的頭像 發表于 08-30 12:42 ?587次閱讀
    基于<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 ?523次閱讀
    基于<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

    基于OpenHarmony標準系統C++公共基礎案例:Semaphore

    1、程序簡介該程序是基于OpenHarmony標準系統C++公共基礎的線程處理:Sempa
    的頭像 發表于 02-10 18:08 ?175次閱讀
    基于<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>案例:Semaphore

    基于OpenHarmony標準系統C++公共基礎案例:ThreadPoll

    1、程序簡介該程序是基于OpenHarmony標準系統C++公共基礎的線程池處理:Thre
    的頭像 發表于 02-10 18:09 ?182次閱讀
    基于<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>案例:ThreadPoll
    主站蜘蛛池模板: 最新久久精品 | 亚洲午夜在线视频 | 色综合图片二区150p | 国产高清在线免费 | 最新中文字幕在线资源 | 天天干 夜夜操 | 亚洲热热久久九九精品 | 毛片色毛片18毛片美女 | 中文字幕佐山爱一区二区免费 | 午夜精品aaa国产福利 | 91aaa免费观看在线观看资源 | 久久影视免费体验区午夜啪啪 | 亚洲精品视频网 | 免费性网站 | 爱爱动态视频免费视频 | 午夜老司机永久免费看片 | 91大神精品在线观看 | 国产精品国产三级国产普通话对白 | 最新免费jlzzjlzz在线播放 | 欧美性天天影视 | 欧美精品啪啪 | 成人国产精品2021 | 国产三级视频 | 理论片一区 | 四虎影院在线免费观看 | 色综合天天色综合 | 天天射天天摸 | 噜噜影院无毒不卡 | 日本一二区视频 | 种子天堂bt磁力在线资源 | 精品特级毛片 | 亚偷熟乱区视频在线观看 | 午夜女同影院 | 久青草免费视频 | 日本不卡视频在线 | 好爽~~~~嗯~~~再快点明星 | 欧美午夜视频一区二区三区 | 久久精品隔壁老王影院 | 97av免费视频 | 国产成人乱码一区二区三区 | 天天操夜夜夜 |