如何使用pthread_t实现线程间通信

在C语言中，pthread_t 是一个用于表示线程的数据类型

1. 首先，包含所需的头文件：

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

2. 定义一个全局变量作为共享数据。这里我们使用一个简单的整数变量作为示例：

int shared_data = 0;

3. 创建一个互斥锁（mutex）以确保线程安全地访问共享数据：

pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;

4. 定义两个线程函数，分别用于生产者和消费者。在这些函数中，我们将使用互斥锁来确保对共享数据的访问是同步的：

void *producer(void *arg) {
    int i;
    for (i = 0; i < 10; i++) {
        pthread_mutex_lock(&lock);
        shared_data++;
        printf("Producer: %d\n", shared_data);
        pthread_mutex_unlock(&lock);
        sleep(1);
    }
    return NULL;
}

void *consumer(void *arg) {
    int i;
    for (i = 0; i < 10; i++) {
        pthread_mutex_lock(&lock);
        printf("Consumer: %d\n", shared_data);
        shared_data--;
        pthread_mutex_unlock(&lock);
        sleep(1);
    }
    return NULL;
}

5. 在主函数中创建两个线程，一个用于生产者，另一个用于消费者：

int main() {
    pthread_t producer_thread, consumer_thread;

    // 创建生产者线程
    if (pthread_create(&producer_thread, NULL, producer, NULL) != 0) {
        perror("Failed to create producer thread");
        exit(1);
    }

    // 创建消费者线程
    if (pthread_create(&consumer_thread, NULL, consumer, NULL) != 0) {
        perror("Failed to create consumer thread");
        exit(1);
    }

    // 等待线程完成
    pthread_join(producer_thread, NULL);
    pthread_join(consumer_thread, NULL);

    // 销毁互斥锁
    pthread_mutex_destroy(&lock);

    return 0;
}

这个示例展示了如何使用 pthread_t 和互斥锁实现线程间通信。生产者线程和消费者线程都可以访问共享数据 shared_data，但是通过使用互斥锁，我们确保了在任何时候只有一个线程可以访问该数据。