linux有建立執行緒的函數,即「pthread_create()」函數。此函數是類別Unix作業系統中建立執行緒的函數,支援四個參數:參數1是指向執行緒標識符的指標、參數2用來設定執行緒屬性、參數3是執行緒運行函數的起始位址、參數4是運行函數的參數。
本教學操作環境:linux5.9.8系統、Dell G3電腦。
linux有創建線程的函數,那就是pthread_create()函數。
pthread_create()是類別Unix作業系統(Unix、Linux、Mac OS X等)中建立執行緒的函數
頭檔
# include<pthread.h>
函數宣告
int pthread_create( pthread_t *restrict tidp, //新创建的线程ID指向的内存单元。 const pthread_attr_t *restrict attr, //线程属性,默认为NULL void *(*start_rtn)(void *), //新创建的线程从start_rtn函数的地址开始运行 void *restrict arg //默认为NULL。上述函数需要参数,将参数放入结构中并将地址作为arg传入。 );
傳回值
若成功則傳回0,否則回傳出錯編號
參數
第一個參數為指向執行緒標識符的指標。
第二個參數用來設定執行緒屬性。
第三個參數是執行緒運行函數的位址。
最後一個參數是運行函數的參數。
注意
在編譯時注意加上-lpthread參數,以呼叫靜態連結函式庫。因為pthread並非Linux系統的預設函式庫。
函數用法
#include <stdio.h> #include <string.h> #include <iostream> #include <pthread.h> #include <unistd.h> #include <vector> #include "main.h" using namespace std; struct Sample { uint32_t index; char sex; uint32_t age; uint32_t result; }; void* TaskEntry(void *args) { Sample *sa = (Sample*)args; uint32_t num = sa->index; if (num == 0) { printf("TaskEntry entry num = 0\n"); // 线程1执行体 sleep(10); printf("TaskEntry entry num = 0 is over!!!\n"); } else if (num == 1) { printf("TaskEntry entry num = 1\n"); // 线程2执行体 sleep(10); printf("TaskEntry entry num = 1 is over!!!\n"); } else if (num == 2) { printf("TaskEntry entry num = 2\n"); // 线程3执行体 sleep(2); printf("TaskEntry entry num = 2 is over!!!\n"); } } uint32_t CreateTask(pthread_t& pid, Sample& sample) { // 假设Sample.index == 2创建任务失败,直接返回 if (sample.index == 2) { return 2; } pthread_attr_t attr; // 设置线程属性 pthread_attr_init(&attr); pthread_attr_setstacksize(&attr, 64 * 1024); // 设置线程栈大小为64KB uint32_t ret = pthread_create(&pid, &attr, (void*(*)(void*))TaskEntry, (void*)&sample); if (ret != 0) { return ret; } pthread_attr_destroy(&attr); // 取消线程的设置属性 return 0; } void VerifyTask(vector<pthread_t>& taskID, vector<Sample>& taskArgs) { void *ret; for (int index = 0; index<2; index++) { // 等待线程结束,释放相应的资源。pthread_join会堵塞主线程不会堵塞其他子线程,然后等待监控的线程执行完成,再返回主线程 // 在此处线程执行顺序为:线程1--主线程--线程2--主线程--线程3 pthread_join(taskID[index], &ret); // 堵塞主线程,执行子线程taskID[index],等待子线程taskID[index]执行完成释放资源 printf("task[%d] is over\n", index); // 主线程执行打印操作 } } int main(void) { // 创建3个线程 vector<pthread_t> taskID(3); vector<Sample> taskArgs(3); for (int i = 0; i < 3; i++) { taskArgs[i] = { i, 'a', 90, 0}; uint32_t ret = CreateTask(taskID[i], taskArgs[i]); if (ret != 0) { // 模拟如下场景:任务创建失败,直接停止前面的任务 for (int j = 0; j<i; j++) { pthread_cancel(taskID[j]); // 子线程1和子线程2延迟10s,当线程3创建失败时,直接让其停止。 } //return ret; // 主线程退出,所有子线程一起退出 } } VerifyTask(taskID, taskArgs); // 校验线程是否结束 printf("three thead is running over!!!\n"); return 0; }
注意編譯的使用需要加上編譯選項-lpthread,例如:g -lpthread main.cpp -o main
#相關推薦:《Linux影片教學》
以上是linux有創建線程的函數嗎的詳細內容。更多資訊請關注PHP中文網其他相關文章!