1、程序簡介

該程序是基于OpenHarmony標準系統(tǒng)的C++公共基礎(chǔ)類庫的線程池處理：ThreadPoll。

本案例完成如下工作：

創(chuàng)建1個線程池，設(shè)置該線程池內(nèi)部有1024個線程空間。

啟動5個線程。每個線程每秒打印1段字符串，10秒后停止。

2、基礎(chǔ)知識

C++公共基礎(chǔ)類庫為標準系統(tǒng)提供了一些常用的C++開發(fā)工具類，包括：

文件、路徑、字符串相關(guān)操作的能力增強接口

讀寫鎖、信號量、定時器、線程增強及線程池等接口

安全數(shù)據(jù)容器、數(shù)據(jù)序列化等接口

各子系統(tǒng)的錯誤碼相關(guān)定義

2.1、添加C++公共基礎(chǔ)類庫依賴

修改需調(diào)用模塊的BUILD.gn，在external_deps或deps中添加如下：

ohos_shared_library("xxxxx") { ... external_deps = [ ... # 動態(tài)庫依賴(可選) "c_utils:utils", # 靜態(tài)庫依賴(可選) "c_utils:utilsbase", # Rust動態(tài)庫依賴(可選) "c_utils:utils_rust", ] ...}

一般而言，我們只需要填寫"c_utils:utils"即可。

2.2、ThreadPoll頭文件

ThreadPoll提供線程安全的線程池功能。

ThreadPoll維護一個任務(wù)隊列，一個線程組。開發(fā)者只需向任務(wù)隊列中注冊需要進行的任務(wù)，線程組執(zhí)行任務(wù)隊列中的任務(wù)。

C++公共基礎(chǔ)類庫的Thread頭文件在：//commonlibrary/c_utils/base/include/thread_pool.h

可在源代碼中添加如下：

#include

命令空間如下：

OHOS::ThreadPool

2.3、OHOS::Thread接口說明

thread_ex.h定義Thread類，該類負責定義Thread類以及相關(guān)接口。

2.3.1、ThreadPool

構(gòu)造函數(shù), 構(gòu)造ThreadPool對象，為線程池內(nèi)線程命名。

explicit ThreadPool(const std::string &name = std::string());

參數(shù)說明：

2.3.2、~ThreadPool

析構(gòu)函數(shù)。

~ThreadPool();

2.3.3、AddTask

向任務(wù)隊列中添加一個Task。若未調(diào)用Start()則直接執(zhí)行Task且不會向任務(wù)隊列添加該Task。

void AddTask(const Task& f);

參數(shù)說明：

2.3.4、GetCurTaskNum

獲取當前任務(wù)數(shù)。

size_t GetCurTaskNum();

返回值說明：

2.3.5、GetMaxTaskNum

獲取最大任務(wù)數(shù)。

size_t GetMaxTaskNum() const;

返回值說明：

2.3.6、GetName

獲取線程池命名。

std::string GetName() const;

返回值說明：

2.3.7、GetThreadsNum

獲取線程池內(nèi)線程數(shù)。

size_t GetThreadsNum() const;

返回值說明：

2.3.8、SetMaxTaskNum

設(shè)置任務(wù)隊列中最大任務(wù)數(shù)。

void SetMaxTaskNum(int maxSize);

參數(shù)說明：

2.3.9、Start

啟動給定數(shù)量threadsNum的線程，執(zhí)行任務(wù)隊列中的任務(wù)。

uint32_t Start(int threadsNum);

參數(shù)說明：

返回值說明：

2.3.10、Stop

停止線程池，等待所有線程結(jié)束。

void Stop();

3、程序解析

3.1、創(chuàng)建編譯引導(dǎo)

在samples/BUILD.gn文件添加一行編譯引導(dǎo)語句。

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

"samples/a24_utils_thread_poll:utils_threadpoll",該行語句表示目錄源代碼 參與編譯。

3.2、創(chuàng)建編譯項目

創(chuàng)建samples/a24_utils_thread_poll 目錄，并添加如下文件：

a24_utils_thread_poll├── utils_thread_poll_sample.cpp # .cpp源代碼├──BUILD.gn#GN文件

3.3、創(chuàng)建BUILD.gn

編輯BUILD.gn文件。

import("http://build/ohos.gni")ohos_executable("utils_threadpoll") { sources = [ "utils_thread_poll_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鍵必須轉(zhuǎn)化為空格，否則會報錯。如果自己不知道如何規(guī)范化，可以：

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

3.4、創(chuàng)建源代碼

3.4.1、創(chuàng)建線程池

引用頭文件，定義OHOS::ThreadPool類對象（即創(chuàng)建線程池）。

#include // 線程池的頭文件
int main(int argc, char **argv){ OHOS::ThreadPool thread_poll("thread_poll_name"); ......}

3.4.2、獲取和設(shè)置線程池最大任務(wù)數(shù)

通過ThreadPool.GetMaxTaskNum()函數(shù)獲取線程池最大任務(wù)數(shù)。

通過ThreadPool.SetMaxTaskNum()函數(shù)設(shè)置線程池最大任務(wù)數(shù)。

具體代碼如下：

int main(int argc, char **argv){ ...... // 查看默認的線程池最大任務(wù)數(shù) cout << "get max task num(default): " << thread_poll.GetMaxTaskNum() << endl; // 設(shè)置線程池的最大任務(wù)數(shù) cout << "set max task num: " << max_task_num << endl; thread_poll.SetMaxTaskNum(max_task_num); // 再查看線程池最大任務(wù)數(shù) cout << "get max task num(set): " << thread_poll.GetMaxTaskNum() << endl; ......}

3.4.3、啟動線程池并添加線程

通過ThreadPool.Start()函數(shù)啟動線程池線程。

通過ThreadPool.AddTask()函數(shù)添加線程，并設(shè)置執(zhí)行函數(shù)。

具體代碼如下：

int main(int argc, char **argv){ ...... // 開啟啟動線程 cout << "start thread: " << start_task_num << endl; thread_poll.Start(start_task_num); for (i = 0; i < start_task_num; i++) { cout << "add task: i = " << i << endl; str_name = "thread_pool_" + to_string(i); auto task = std::bind(func, str_name); // 添加任務(wù)到線程池中，并啟動運行 thread_poll.AddTask(task); sleep(1); } ......}

3.4.4、編寫線程執(zhí)行函數(shù)

每秒打印一段信息，10秒后退出。

void func(const std::string &name){ for (int i = 0; i < 10; i++) { cout << "func: " << name << " and i = " << i << endl; sleep(1); }}

3.4.5、主程序等待線程池全部退出

通過ThreadPool.Start()函數(shù)啟動線程池線程。

具體代碼如下：

int main(int argc, char **argv){ // 等待關(guān)閉所有的線程，會等待線程池程序全部結(jié)束才返回 cout << "stop thread: start" << endl; thread_poll.Stop(); cout << "stop thread: end" << endl; return 0;}

4、運行程序

系統(tǒng)啟動后，運行命令：

utilsthreadpoll

5、運行結(jié)果

運行結(jié)果：

# utils_threadpollget max task num(default): 0set max task num: 1024get max task num(set): 1024start thread: 5add task: i = 0func: thread_pool_0 and i = 0add task: i = 1func: thread_pool_0 and i = 1func: thread_pool_1 and i = 0add task: i = 2func: thread_pool_0 and i = 2func: thread_pool_1 and i = 1func: thread_pool_2 and i = 0add task: i = 3func: thread_pool_0 and i = 3func: thread_pool_1 and i = 2func: thread_pool_3 and i = 0func: thread_pool_2 and i = 1func: thread_pool_0 and i = 4func: thread_pool_3 and i = 2add task: i = 1func: thread_pool_2 and i = 42func: thread_pool_1 and i = 3func: thread_pool_4 and i = 0func: thread_pool_0 and i = 5func: thread_pool_3 and i = 2func: thread_pool_1 and i = 4func: thread_pool_2 and i = 3stop thread: startfunc: thread_pool_4 and i = 1func: thread_pool_0 and i = 6func: thread_pool_1 and i = 5func: thread_pool_3 and i = 3func: thread_pool_4 and i = 2func: thread_pool_2 and i = 4func: thread_pool_0 and i = 7func: thread_pool_1 and i = 6func: thread_pool_3 and i = 4func: thread_pool_2 and i = 5func:thread_pool_4 and i = 3func: thread_pool_0 and i = 8func: thread_pool_1 and i = 7func: thread_pool_3 and i = 5func: thread_pool_2 and i = 6func: thread_pool_4 and i = 4func: thread_pool_0 and i = 9func: thread_pool_1 and i = 8func: thread_pool_3 and i = 6func: thread_pool_2 and i = func: thread_pool_4 and i = 57func: thread_pool_1 and i = 9func: thread_pool_3 and i = 7func: thread_pool_4 and i = 6func: thread_pool_2 and i = 8func: thread_pool_3 and i = 8func: thread_pool_4 and i = 7func: thread_pool_2 and i = 9func: thread_pool_3 and i = 9func: thread_pool_4 and i = 8func: thread_pool_4 and i = 9stop thread: end#

注意：

（1）因有10個線程做出打印信息，故上述打印信息各有不同。