如何实现工作线程无阻塞循环并响应主线程停止信号？

当然有办法实现这种需求！你的问题核心在于对pthread_cond_wait的用法理解有点偏差，咱们一步步来修正并实现预期效果。

原代码的问题分析 #

你的线程回调里，每次进入while循环后只执行了一次i++就调用pthread_cond_wait阻塞了——这意味着线程大部分时间都在休眠，只有当主线程发送条件信号时才会醒来执行一次循环体，完全达不到“持续运行”的目的。

正确的实现方式 #

我们需要让线程持续执行任务，同时能响应主线程的停止信号。核心思路是：

• 执行实际任务时不要持有互斥锁，避免阻塞主线程修改停止信号或发送条件信号
• 每次任务执行完成后，重新获取锁检查停止信号，若未收到则继续执行，否则退出

修改后的线程回调代码 #

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

// 全局停止信号和同步原语（实际项目中建议封装到结构体，避免全局变量）
volatile int stopSignal = 0;
pthread_mutex_t stopSignalGuard = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t stopCondition = PTHREAD_COND_INITIALIZER;

// 假设你已实现线程安全的打印函数
void syncPrint(const char *format, ...);

void *threadCallback(void *threadID) {
    long tid = (long)threadID;
    syncPrint("Thread %lu started. Waiting for stop signal\n", tid);

    while (1) {
        // 1. 执行实际业务逻辑（此处无需持有锁）
        static __thread int i = 0; // 用线程局部变量避免竞争
        i++;
        syncPrint("Thread %lu increment: %d\n", tid, i);

        // 2. 持有锁检查停止信号
        pthread_mutex_lock(&stopSignalGuard);
        if (stopSignal) {
            syncPrint("Stop signal received. Thread %lu will terminate...\n", tid);
            pthread_mutex_unlock(&stopSignalGuard);
            break;
        }
        // 3. 未收到信号则等待（可选：也可以直接解锁继续循环，但会占用更多CPU）
        pthread_cond_wait(&stopCondition, &stopSignalGuard);
        pthread_mutex_unlock(&stopSignalGuard);
    }

    pthread_exit(NULL);
}

主线程控制代码示例 #

int main() {
    pthread_t threads[3];
    long i;

    // 创建工作线程
    for (i = 0; i < 3; i++) {
        pthread_create(&threads[i], NULL, threadCallback, (void *)i);
    }

    // 模拟主线程运行一段时间后触发停止
    sleep(5);

    // 发送停止信号：必须在持有锁的情况下修改并广播
    pthread_mutex_lock(&stopSignalGuard);
    stopSignal = 1;
    pthread_cond_broadcast(&stopCondition); // 唤醒所有等待的线程
    pthread_mutex_unlock(&stopSignalGuard);

    // 等待所有线程终止
    for (i = 0; i < 3; i++) {
        pthread_join(threads[i], NULL);
    }

    // 清理同步资源
    pthread_mutex_destroy(&stopSignalGuard);
    pthread_cond_destroy(&stopCondition);

    return 0;
}

其他可选方案 #

• 原子变量轮询：用_Atomic bool代替普通int作为停止信号，线程无需互斥锁直接轮询检查。这种方式实现简单，但会持续占用CPU，适合任务执行时间短、对CPU消耗不敏感的场景。
• pthread_cancel：主线程直接调用pthread_cancel终止线程，但这种方式较为暴力，可能导致线程持有资源未释放（如锁、文件句柄），除非你在线程中设置了安全的取消点，否则不推荐使用。

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