使用条件变量同步线程绘制曼德博集合时输出异常问题排查

核心错误：把if替换成while #

条件变量存在虚假唤醒，且线程被唤醒后原等待条件可能已不成立（比如其他线程抢先处理了目标行），必须用while循环重新校验条件，不能用if一次性判断：

pthread_mutex_lock(&mutex);
// 循环判断，直到条件满足
while (current_line >= total_lines) {
    pthread_cond_wait(&cond, &mutex);
}
// 原子获取要处理的行号
int target_line = current_line++;
pthread_mutex_unlock(&mutex);

// 执行计算
compute_mandel_line(target_line, line_buffer);

信号发送的正确时机 #

1. 主线程启动后触发初始信号：所有线程启动后，主线程需要发送信号唤醒等待的计算线程，避免线程一直阻塞在pthread_cond_wait。
2. 计算完成后通知输出线程：如果计算和输出是分离线程，计算线程完成一行后，必须在锁内标记结果就绪，再发送信号给输出线程：

// 计算完成后存入结果，通知输出
pthread_mutex_lock(&mutex);
result_data[target_line] = line_buffer;
is_ready[target_line] = 1;
pthread_cond_signal(&output_cond);
pthread_mutex_unlock(&mutex);

任务分配的原子性保护 #

全局行号变量（比如current_line）的读取和递增必须在互斥锁内完成，否则会出现多个线程拿到同一行的竞态问题，导致重复计算或结果混乱。

分离计算与输出的双条件变量方案（如果分工明确） #

如果用一组线程计算、一组线程输出，需要两个条件变量分别同步计算任务和输出任务：

// 计算线程逻辑
void *compute_thread(void *arg) {
    while (1) {
        pthread_mutex_lock(&mutex);
        while (calc_line >= total_lines) {
            pthread_cond_wait(&calc_cond, &mutex);
            // 所有行计算完成，退出线程
            if (calc_line >= total_lines) {
                pthread_mutex_unlock(&mutex);
                return NULL;
            }
        }
        int line = calc_line++;
        pthread_mutex_unlock(&mutex);
        
        compute_mandel_line(line, result_buf[line]);
        
        pthread_mutex_lock(&mutex);
        is_ready[line] = 1;
        pthread_cond_signal(&output_cond);
        pthread_mutex_unlock(&mutex);
    }
}

// 输出线程逻辑
void *output_thread(void *arg) {
    while (1) {
        pthread_mutex_lock(&mutex);
        while (output_line >= total_lines || !is_ready[output_line]) {
            pthread_cond_wait(&output_cond, &mutex);
            // 所有行输出完成，退出线程
            if (output_line >= total_lines) {
                pthread_mutex_unlock(&mutex);
                return NULL;
            }
        }
        int line = output_line++;
        pthread_mutex_unlock(&mutex);
        
        output_mandel_line(line, result_buf[line]);
    }
}

主线程的收尾等待 #

主线程必须等待所有计算和输出线程完成后再退出，避免程序提前终止导致结果不完整：

// 启动所有计算和输出线程后
for (int i = 0; i < compute_thread_num; i++) {
    pthread_join(compute_threads[i], NULL);
}
for (int i = 0; i < output_thread_num; i++) {
    pthread_join(output_threads[i], NULL);
}

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