CentOS 使用线程库Pthread 库

た入场券 2024-02-21 12:20 50阅读 0赞

## 1、Pthread 库说明 ##

pthread 库是Linux系统默认线程库。

在Linux 系统环境中，编辑C/C++程序使用pthread 库，需要添加对应的头文件，并链接pthread库。

#include<pthread.h>

## 2、Pthread 库核心方法 ##

### pthread\_create ###

**函数定义：**

int pthread_create(pthread_t* thread, const pthread_attr_t* attr, void*(*start_routine)(void*), void* arg);

**参数说明：**

**pthread\_t** 定义如下：

typedef unsigned long int pthread_t;

**thread** 是一个指向线程标识符的指针，线程调用后，改值被设置为线程ID

**attr** 用来设置线程属性

**start\_routine** 是线程函数的其实地址，即线程函数体，线程创建成功后，thread 指向的内存单元从该地址开始运行

**arg** 是传递给线程函数体的参数

**返回值：**

若线程创建成功，则返回0，失败则返回错误码，并且 thread 内容是未定义的。

### pthread\_join ###

**函数定义：**

int pthread_join(pthread_t thread, void **retval);

**参数说明：**

**thread** 是线程表示符

**retval** 用来获取线程的返回值，一般是 pthread\_join 方法传递出来的值

**功能说明：**

这是一个线程阻塞函数，调用该函数则等到线程结束才继续运行

### pthread\_exit ###

**函数定义：**

void pthread_exit(void *retval);

**参数说明：**

**retval** 是线程的退出码，传递给创建线程的地方

**功能说明：**

一个线程的结束有两种途径：

*  线程函数体执行结束；
 *  调用 pthread\_exit 方法退出线程；

### pthread\_self ###

**函数定义:**

pthread_t pthread_self();

**功能说明：**

用来获取当前线程ID

### pthraad\_detach ###

**函数定义：**

int pthread_detach (pthread_t __th)

**功能说明:**

分离线程

## 3、Pthread 库线程属性说明 ##

#### 线程属性 ####

设置线程不同属性有不同属性有不同的方法，但是都需要先初始化属性数据结构，初始化函数为：

int pthread_attr_init(pthread_attr_t *__attr);

线程属性包括：

1.  作用域；
2.  栈大小；
3.  栈地址；
4.  优先级；
5.  分离状态；
6.  调度策略；
7.  调度参数；

#### 分离状态 ####

线程终止时，系统将不再保留线程终止状态；当不需要线程的终止状态时，可以分离线程（调用 pthread\_detach 函数），也可以通过设置线程的分离状态实现

int pthread_attr_getdetachstate(const pthread_attr_t* attr, int* state);
    int pthread_attr_setdetachstate(pthread_attr_t* attr, int state);

state 的值可以是 PTHREAD\_CREATE\_DETACHED 和 PTHREAD\_CREATE\_JOINABLE，分别表示主线程阻塞和子线程剥离

#### 线程优先级 ####

新线程的优先级默认为0

int  pthread_attr_getschedparam(const pthread_attr_t *restrict attr, struct sched_param *restrict param) ;
    int pthread_attr_setschedparam(pthread_attr *restrict attr, const struct sched_param* restrict param);

#### 继承父优先级 ####

新线程不继承父线程的调度优先级

#### 调度策略 ####

线程使用 SCHED\_OTHER 调度策略，线程一旦开始运行，直到被强占或者直到线程阻塞或者停止位置

int pthread_attr_setschedpolicy(pthread_attr_t* attr, int policy);
    int pthread_attr_setschedparam(pthread_attr_t* attr, struct sched_param* param)

## 4、Pthread 示例代码 ##

前提：在/usr/local/source\_code目录下新增thread\_demo 目录，并在此目录下新建init\_thread.cpp，文件内容如下：

#include <pthread.h>
    #include <iostream>
    
    using namespace std;
    
    void* printHello(void* args) {
        cout << "Hello World from Thread" << endl;
        return NULL;
    }
    
    int main() {
        pthread_t thread;
    
        if (pthread_create(&thread, NULL, &printHello, NULL)) {
            cout << "Error creating thread" << endl;
            return 1;
        }
    
        if (pthread_join(thread, NULL)) {
            cout << "Error joining thread" << endl;
            return 2;
        }
    
        return 0;
    }

编译执行：

g++ init_thread.cpp -o init_thread  -L/usr/local/lib/ -lpthread

控制台输出:

[root@localhost thread_demo]# g++ init_thread.cpp -o init_thread  -L/usr/local/lib/ -lpthread
    [root@localhost thread_demo]# ll
    总用量 16
    -rwxr-xr-x. 1 root root 9136 10月 24 14:44 init_thread
    -rw-r--r--. 1 root root  459 10月 24 14:30 init_thread.cpp
    [root@localhost thread_demo]# ./init_thread
    Hello World from Thread