gdb 多线程

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

#define BUFFER_SIZE 5

int buffer[BUFFER_SIZE];  // 共享缓冲区
int count = 0;           // 当前缓冲区中的数据量

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;      // 互斥锁
pthread_cond_t cond_producer = PTHREAD_COND_INITIALIZER; // 条件变量（生产者）
pthread_cond_t cond_consumer = PTHREAD_COND_INITIALIZER; // 条件变量（消费者）

// 生产者线程函数
void *producer(void *arg) {
    for (int i = 0; i < 10; i++) {
        pthread_mutex_lock(&mutex);
        while (count == BUFFER_SIZE) {  // 缓冲区满，等待
            printf("Producer waiting...\n");
            pthread_cond_wait(&cond_producer, &mutex);
        }
        buffer[count++] = i;  // 生产数据
        printf("Produced: %d (count=%d)\n", i, count);
        pthread_cond_signal(&cond_consumer);  // 唤醒消费者
        pthread_mutex_unlock(&mutex);
        sleep(1);  // 模拟生产耗时
    }
    return NULL;
}

// 消费者线程函数
void *consumer(void *arg) {
    for (int i = 0; i < 10; i++) {
        pthread_mutex_lock(&mutex);
        while (count == 0) {  // 缓冲区空，等待
            printf("Consumer waiting...\n");
            pthread_cond_wait(&cond_consumer, &mutex);
        }
        int data = buffer[--count];  // 消费数据
        printf("Consumed: %d (count=%d)\n", data, count);
        pthread_cond_signal(&cond_producer);  // 唤醒生产者
        pthread_mutex_unlock(&mutex);
        sleep(2);  // 模拟消费耗时
    }
    return NULL;
}

int main() {
    pthread_t tid_producer, tid_consumer;

    // 创建生产者和消费者线程
    pthread_create(&tid_producer, NULL, producer, NULL);
    pthread_create(&tid_consumer, NULL, consumer, NULL);

    // 等待线程结束
    pthread_join(tid_producer, NULL);
    pthread_join(tid_consumer, NULL);

    return 0;
}