如何利用pthread_t实现并发控制

pthread_t 是 POSIX 线程库中表示线程的数据类型

1. 包含头文件：在你的源代码文件中，需要包含 <pthread.h> 头文件。

#include <pthread.h>

2. 定义线程函数：创建一个线程函数，该函数将在新线程中运行。线程函数应该接受一个 void * 类型的参数，并返回一个 void * 类型的值。

void *thread_function(void *arg) {
    // 在这里编写你的线程执行代码
    return NULL;
}

3. 创建线程变量：定义一个 pthread_t 类型的变量，用于存储线程的 ID。

pthread_t thread_id;

4. 创建线程：使用 pthread_create() 函数创建一个新线程。该函数需要三个参数：指向线程 ID 的指针、线程属性（通常为 NULL）和线程函数的地址。

int result = pthread_create(&thread_id, NULL, thread_function, NULL);
if (result != 0) {
    printf("Error creating thread: %d\n", result);
    exit(1);
}

5. 等待线程结束（可选）：如果你需要等待线程完成其任务，可以使用 pthread_join() 函数。该函数需要两个参数：线程 ID 和一个指向 void * 类型的指针，用于存储线程函数的返回值。

void *return_value;
int result = pthread_join(thread_id, &return_value);
if (result != 0) {
    printf("Error joining thread: %d\n", result);
    exit(1);
}

6. 使用互斥锁或其他同步原语来实现并发控制。例如，使用 pthread_mutex_t 类型的互斥锁来保护共享资源。

#include <pthread.h>
#include<stdio.h>
#include <stdlib.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int shared_counter = 0;

void *thread_function(void *arg) {
    for (int i = 0; i < 100000; i++) {
        pthread_mutex_lock(&mutex);
        shared_counter++;
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}

int main() {
    const int NUM_THREADS = 10;
    pthread_t threads[NUM_THREADS];

    for (int i = 0; i < NUM_THREADS; i++) {
        int result = pthread_create(&threads[i], NULL, thread_function, NULL);
        if (result != 0) {
            printf("Error creating thread: %d\n", result);
            exit(1);
        }
    }

    for (int i = 0; i < NUM_THREADS; i++) {
        void *return_value;
        int result = pthread_join(threads[i], &return_value);
        if (result != 0) {
            printf("Error joining thread: %d\n", result);
            exit(1);
        }
    }

    printf("Shared counter: %d\n", shared_counter);
    return 0;
}

这个示例展示了如何使用 pthread_t、互斥锁和其他 POSIX 线程函数来实现并发控制。注意，这个示例仅用于演示目的，实际应用中可能需要更复杂的错误处理和资源管理。