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

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

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

3天內不再提示

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

福州市凌睿智捷電子有限公司 ? 2024-08-30 12:42 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

1、程序簡介

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

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

創建3個讀線程,每個讀線程循環5次,每次循環獲取讀鎖,將公共資源變量打印,睡眠1秒,然后釋放讀鎖,最后再睡眠1秒。

創建3個寫線程,每個寫線程循環5次,每次循環獲取寫鎖,將公共資源變量打印,睡眠1秒,然后釋放讀鎖,最后再睡眠1秒。

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

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

可在源代碼中添加如下:

#include

OpenHarmony讀寫鎖分為如下三大類:

(1)RWLock類

OHOS::RWLock

(2)UniqueWriteGuard類

OHOS::UniqueWriteGuard

(3)UniqueReadGuard類

OHOS::UniqueReadGuard

2.3、OHOS::RWLock接口說明

2.3.1、RWLock

構造函數。

RWLock() : RWLock(true);RWLock(bool writeFirst);

參數說明:

參數名稱類型參數說明
writeFirstbool是否優先寫模式

2.3.2、~RWLock

析構函數。

~RWLock();

2.3.3、LockRead

獲取讀鎖。

void LockRead();

2.3.4、UnLockRead

釋放讀鎖。

void UnLockRead();

2.3.5、LockWrite

獲取寫鎖。

void LockWrite();

2.3.6、UnLockWrite

獲取寫鎖。

void UnLockWrite();

2.4、OHOS::UniqueWriteGuard接口說明

2.4.1、UniqueWriteGuard

構造函數。

UniqueWriteGuard(RWLockable &rwLockable)

參數說明:

參數名稱類型參數說明
rwLockableRWLockabletemplate

2.4.2、~UniqueWriteGuard

析構函數。

~UniqueWriteGuard();

2.5、OHOS::UniqueReadGuard接口說明

2.5.1、UniqueReadGuard

構造函數。

UniqueReadGuard(RWLockable &rwLockable)

參數說明:

參數名稱類型參數說明
rwLockableRWLockabletemplate

2.5.2、~UniqueReadGuard

析構函數。

~UniqueReadGuard();

3、程序解析

3.1、創建編譯引導

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

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

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

3.2、創建編譯項目

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

a25_utils_rwlock├── utils_rwlock_sample.cpp # .cpp源代碼├──BUILD.gn#GN文件

3.3、創建BUILD.gn

編輯BUILD.gn文件。

import("http://build/ohos.gni")ohos_executable("utils_rwlock") { sources = [ "utils_rwlock_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}

注意:

(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、創建讀寫鎖和公共資源變量

static OHOS::RWLock m_rwlock(true);static int m_count = 0;

3.4.2、創建線程池并設置

int main(int argc, char **argv){ OHOS::ThreadPool threads("name_semaphore_threads"); int threads_start = 6; ...... threads.SetMaxTaskNum(128); threads.Start(threads_start); ......}

3.4.3、啟動3個讀線程和3個寫線程

調用AddTask()添加子線程。

// 啟動讀線程for (int i = 0; i < 3; i++) { str_name = "thread_read_" + to_string(i); auto task = std::bind(funcRead, str_name); threads.AddTask(task);}
// 啟動寫線程for (int i = 0; i < 3; i++) { str_name = "thread_write_" + to_string(i); auto task = std::bind(funcWrite, str_name); threads.AddTask(task);}

3.4.4、編寫讀線程

讀線程完成如下步驟:

調用LockRead()獲取讀鎖;

如果獲取到讀鎖,打印公共資源變量,并睡眠1秒;

調用UnLockRead()釋放讀鎖;

睡眠1秒;

上述操作循環5次;

static void funcRead(const string& name){ cout << get_curtime() << ", " << name << ": start\n";
for (int i = 0; i < 5; i++) { cout << get_curtime() << ", " << name << ": LockRead wait..." << endl; m_rwlock.LockRead(); cout << get_curtime() << ", " << name << ": LockRead success and read count = " << m_count << " and sleep 1 sec" << endl; sleep(1); m_rwlock.UnLockRead(); cout << get_curtime() << ", " << name << ": UnLockRead" << endl; sleep(1); }}

3.4.5、編寫寫線程

寫線程完成如下步驟:

調用LockWrite()獲取寫鎖;

如果獲取到讀鎖,公共資源變量累加1,并睡眠1秒;

調用UnLockWrite()釋放寫鎖;

睡眠1秒;

上述操作循環5次;

static void funcWrite(const string& name){ cout << get_curtime() << ", " << name << ": start\n";
for (int i = 0; i < 5; i++) { cout << get_curtime() << ", " << name << ": LockWrite wait..." << endl; m_rwlock.LockWrite(); cout << get_curtime() << ", " << name << ": LockWrite success and write count++ and sleep 1 sec" << endl; m_count++; sleep(1); m_rwlock.UnLockWrite(); cout << get_curtime() << ", " << name << ": UnLockWrite" << endl; sleep(1); }}

4、編譯步驟

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

hb build -f

5、運行結果

# utils_rwlock2017-8-5 208, thread_read_0: start2017-8-5 20:7:8, thread_read_0: LockRead wait...2017-8-5 20:7:8, thread_read_0: LockRead success and read count = 0 and sleep 1 sec2017-8-5 20:7:8, thread_read_1: start2017-8-5 20:7:8, thread_read_1: LockRead wait...2017-8-5 20:7:8, thread_read_1: LockRead success and read count = 0 and sleep 1 sec2017-8-5 20:7:8, thread_read_2: start2017-8-5 20:7:8, thread_read_2: LockRead wait...2017-8-5 20:7:8, thread_read_2: LockRead success and read count = 0 and sleep 1 sec2017-8-5 20:7:8, thread_write_0: start2017-8-5 20:7:8, thread_write_0: LockWrite wait...2017-8-5 20:7:8, thread_write_1: start2017-8-5 20:7:8, thread_write_1: LockWrite wait...2017-8-5 20:7:9, thread_read_0: UnLockRead2017-8-5 20:7:9, thread_read_1: UnLockRead2017-8-5 20:7:9, thread_read_2: UnLockRead2017-8-5 20:7:9, thread_write_1: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:10, thread_read_0: LockRead wait...2017-8-5 20:7:10, thread_write_1: UnLockWrite2017-8-5 20:7:10, thread_write_0: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:10, thread_read_1: LockRead wait...2017-8-5 20:7:10, thread_read_2: LockRead wait...2017-8-5 20:7:112017-8-5 20:7:11, thread_write_0, thread_read_0: LockRead success and read count = : UnLockWrite2 and sleep 1 sec2017-8-5 20:7:11, thread_read_1: LockRead success and read count = 2 and sleep 1 sec2017-8-5 20:7:11, thread_write_1: LockWrite wait...2017-8-5 20:7:12, thread_write_0: LockWrite wait...2017-8-5 20:7:12, thread_read_1: UnLockRead2017-8-5 20:7:12, thread_read_0: UnLockRead2017-8-5 20:7:12, thread_write_0: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:13, thread_read_1: LockRead wait...2017-8-5 20:7:13, thread_read_0: LockRead wait...2017-8-5 20:7:13, thread_write_0: UnLockWrite2017-8-5 20:7:13, thread_write_1: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:14, thread_write_0: LockWrite wait...2017-8-5 20:7:14, thread_write_1: UnLockWrite2017-8-5 20:7:14, thread_write_0: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:15, thread_read_0: LockRead success and read count = 2017-8-5 20:7:15, thread_write_0: UnLockWrite2017-8-5 20:7:15, thread_write_1: LockWrite wait...2017-8-5 20:7:15, thread_read_1: LockRead success and read count = 5 and sleep 1 sec5 and sleep 1 sec2017-8-5 20:7:16, thread_write_0: LockWrite wait...2017-8-5 20:7:16, thread_read_1: UnLockRead2017-8-5 20:7:16, thread_read_0: UnLockRead2017-8-5 20:7:16, thread_write_1: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:17, thread_read_1: LockRead wait...2017-8-5 20:7:17, thread_read_0: LockRead wait...2017-8-5 20:7:17, thread_write_1: UnLockWrite2017-8-5 20:7:17, thread_write_0: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:18, thread_write_1: LockWrite wait...2017-8-5 20:7:18, thread_write_1: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:18,thread_write_0: UnLockWrite2017-8-5 20:7:192017-8-5 20:7:19, thread_write_0, thread_write_1: UnLockWrite: LockWrite wait...2017-8-5 20:7:19,
thread_read_1: LockRead success and read count = 8 and sleep 1 sec2017-8-5 20:7:19, thread_read_0: LockRead success and read count = 8 and sleep 1 sec2017-8-5 20:7:19, thread_read_2: LockRead success and read count = 8 and sleep 1 sec2017-8-5 20:7:20, thread_write_1: LockWrite wait...2017-8-5 20:7:20, thread_read_1: UnLockRead2017-8-5 20:7:20, thread_read_0: UnLockRead2017-8-5 20:7:20, thread_read_2: UnLockRead2017-8-5 20:7:20, thread_write_1: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:21, thread_read_1: LockRead wait...2017-8-5 20:7:21, thread_read_0: LockRead wait...2017-8-5 20:7:21, thread_read_2: LockRead wait...2017-8-5 20:7:21, thread_write_1: UnLockWrite2017-8-5 20:7:21, thread_write_0: LockWrite success and write count++ and sleep 1 sec2017-8-5 20:7:22, thread_write_0: UnLockWrite2017-8-5 20:7:22, thread_read_0: LockRead success and read count = 10 and sleep 1 sec2017-8-5 20:7:22, thread_read_1: LockRead success and read count = 10 and sleep 1 sec2017-8-5 20:7:22, thread_read_2: LockRead success and read count = 10 and sleep 1 sec2017-8-5 20:7:23, thread_read_0: UnLockRead2017-8-5 20:7:23, thread_read_1: UnLockRead2017-8-5 20:7:23, thread_read_2: UnLockRead2017-8-5 20:7:24, thread_read_2: LockRead wait...2017-8-5 20:7:24, thread_read_2: LockRead success and read count = 10 and sleep 1 sec2017-8-5 20:7:25, thread_read_2: UnLockRead2017-8-5 20:7:26, thread_read_2: LockRead wait...2017-8-5 20:7:26, thread_read_2: LockRead success and read count = 10 and sleep 1 sec2017-8-5 20:7:27, thread_read_2: UnLockRead#

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

    關注

    117

    文章

    3826

    瀏覽量

    82813
  • 系統
    +關注

    關注

    1

    文章

    1032

    瀏覽量

    21797
  • OpenHarmony
    +關注

    關注

    29

    文章

    3847

    瀏覽量

    18488
收藏 人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評論

    相關推薦
    熱點推薦

    基于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++公共基礎標準系統提供了一些常用的C+
    發表于 08-21 10:56

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

    /a28_utils_safestack 2、基礎知識 C++公共基礎標準系統提供了一些常用的C+
    發表于 08-21 14:51

    OpenHarmony C++公共基礎應用案例:Thread

    1、程序簡介該程序是基于OpenHarmonyC++公共基礎的線程處理:Thread。該應用案例已在
    的頭像 發表于 11-23 08:22 ?1266次閱讀
    <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 ?960次閱讀
    <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 ?835次閱讀
    <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 ?571次閱讀
    基于<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。線程安全隊列,是在dequeue的基礎
    的頭像 發表于 08-30 12:41 ?672次閱讀
    基于<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 ?664次閱讀
    基于<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 ?756次閱讀
    基于<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++公共基礎案例:Semaphore

    1、程序簡介該程序是基于OpenHarmony標準系統C++公共基礎的線程處理:Sempa
    的頭像 發表于 02-10 18:08 ?324次閱讀
    基于<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 ?351次閱讀
    基于<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
    主站蜘蛛池模板: 亚洲综合激情另类专区 | 午夜毛片视频高清不卡免费 | 婷婷亚洲五月琪琪综合 | 亚洲成在人 | 婷婷丁香四月 | 欧美人与z0xxxx另类 | 么公的好大好硬好深好爽在线视频 | 天堂中文资源网 | 九九视频这里只有精品 | 97影院理伦在线观看 | 午夜爽爽性刺激一区二区视频 | 国产精品视频久久久久久 | 色伊人网 | 亚洲免费色 | 天天干影院 | 国产精品美女免费视频大全 | 丁香婷婷综合五月综合色啪 | 久久五月女厕所一区二区 | 卡1卡2卡3精品推荐老狼 | 日本在线一本 | 欧美肉到失禁高h视频在线 欧美三级成人 | 亚洲一区二区三区四 | 六月综合网 | 午夜视频网址 | 天天干夜夜爽天天操夜夜爽视频 | 免费网址视频在线看 | 一二三区在线视频 | 天天影视亚洲 | 美女隐私黄www视频 美女用手扒开尿口给男生桶爽 | 亚洲色图在线观看视频 | 欧美综合久久 | 中文字幕三级久久久久久 | 藏经阁在线观看 | 美女被曹 | 人人搞人人 | 视频免费在线 | 岛国片欧美一级毛片 | 黄色国产在线观看 | 欧美精品一区二区三区视频 | 国产成人精品一区 | 扒开双腿猛进入jk校视频 |