pthread_cond_wait仅当共享值设为0时唤醒接收线程的问题排查问询

核心常见原因 #

你遇到的问题90%以上是条件判断逻辑与等待逻辑不匹配导致的，按优先级排列常见触发原因如下：

• 条件等待的判断逻辑写反
  pthread_cond_wait被唤醒后，会首先重新判断你写的等待条件，只有条件不成立时才会退出等待执行后续逻辑。如果你在接收线程里写的判断逻辑是while(共享值 != 0) { 调用wait }，那只有共享值为0时才会跳出等待，非0值就算收到唤醒信号，也会因为条件成立再次进入等待，表现上就是没被唤醒。
• 共享变量未加互斥锁保护
  pthread条件变量必须和互斥锁绑定使用，所有对和条件变量关联的共享变量的读写操作，都必须持有同一把互斥锁。如果发送线程写入数值时没加锁，CPU缓存不会同步到内存，接收线程感知不到非0值的更新，会一直判定等待条件成立，继续阻塞。
• 使用非法占位值
  如果你把共享变量的初始值设为0，接收线程的等待逻辑是while(共享值 == 0) 等待，就会出现只有新输入的0才能跳出循环的问题，因为非0输入会被判定为条件不成立直接执行后续逻辑，但如果后续逻辑处理完没重置占位值，也会出现异常。
• 虚假唤醒未处理
  如果你用if而不是while包裹pthread_cond_wait调用，会出现虚假唤醒后拿到无效值的问题，但这个问题一般不会只在输入0时生效，属于通用错误点。

可参考的正确实现模板 #

全局/共享结构定义 #

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

// 定义无效占位值，需和用户正常输入的数值范围错开
#define INVALID_VAL -1

typedef struct {
    int value;
} shared_data_t;

shared_data_t shared_data;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

接收线程实现 #

void* recv_thread_func(void* arg) {
    pthread_mutex_lock(&mutex);
    while (1) {
        // 等待有新的有效输入
        while (shared_data.value == INVALID_VAL) {
            pthread_cond_wait(&cond, &mutex);
        }
        // 输入为0时退出线程
        if (shared_data.value == 0) {
            break;
        }
        // 处理非0的有效输入
        printf("接收线程处理数值：%d\n", shared_data.value);
        // 处理完成后重置为占位值，等待下一次输入
        shared_data.value = INVALID_VAL;
    }
    pthread_mutex_unlock(&mutex);
    return NULL;
}

发送线程实现 #

void* send_thread_func(void* arg) {
    int input;
    while (1) {
        scanf("%d", &input);
        // 写入共享变量前必须加锁
        pthread_mutex_lock(&mutex);
        shared_data.value = input;
        // 写入完成后发送唤醒信号
        pthread_cond_signal(&cond);
        pthread_mutex_unlock(&mutex);
        // 输入为0时退出发送线程
        if (input == 0) {
            break;
        }
    }
    return NULL;
}

排查步骤 #

1. 首先检查接收线程的条件判断逻辑，确认等待条件是否和预期的唤醒条件一致
2. 检查所有读写共享变量的位置是否都加了同一把互斥锁
3. 检查共享变量的初始值是否是合法占位值，没有和用户输入范围重叠

内容的提问来源于stack exchange，提问作者Rex Brown