如何创建支持非阻塞键盘输入退出的无限循环？线程并行问题求助

嘿，我来帮你搞定这个问题！你遇到的核心问题主要是线程函数的签名不符合pthread规范，再加上对线程执行逻辑和同步处理的细节没理清。咱们一步步来解决：

1. 核心问题：线程函数签名错误 #

pthread库要求线程入口函数的签名必须是 void *(*)(void *)——也就是参数是void*类型，返回值也得是void*。你写的void *check(int *q)不符合这个规范，这会直接导致线程创建失败或者运行时出现未定义行为。

2. 额外注意：线程同步与阻塞处理 #

getchar()是阻塞函数，把它放在监听线程里会让这个线程一直等待输入；同时全局变量的跨线程访问需要加互斥锁，避免出现竞态条件。

修正后的完整可运行代码 #

#include <stdio.h>
#include <pthread.h>
#include <unistd.h> // 用于sleep模拟循环任务
#include <perror.h>

// 全局标记：控制循环是否退出
int should_exit = 0;
// 互斥锁：保护should_exit的跨线程访问
pthread_mutex_t exit_mutex;

// 监听键盘输入的线程函数（符合pthread规范）
void *check_input(void *arg) {
    // 阻塞等待用户输入任意字符（包括回车）
    getchar();
    
    // 加锁修改退出标记，确保原子性
    pthread_mutex_lock(&exit_mutex);
    should_exit = 1;
    pthread_mutex_unlock(&exit_mutex);
    
    return NULL;
}

// 主线程的持续运行逻辑
void main_loop() {
    int loop_count = 0;
    while (1) {
        // 加锁检查退出标记
        pthread_mutex_lock(&exit_mutex);
        if (should_exit) {
            pthread_mutex_unlock(&exit_mutex);
            break;
        }
        pthread_mutex_unlock(&exit_mutex);
        
        // 模拟你的持续运行任务
        printf("循环运行中，当前计数：%d\n", loop_count++);
        sleep(1); // 暂停1秒，避免输出刷屏
    }
    printf("检测到键盘输入，循环已退出\n");
}

int main() {
    pthread_t input_thread;
    int create_ret;
    
    // 初始化互斥锁
    pthread_mutex_init(&exit_mutex, NULL);
    
    // 创建监听输入的线程
    create_ret = pthread_create(&input_thread, NULL, check_input, NULL);
    if (create_ret != 0) {
        perror("线程创建失败");
        return 1;
    }
    
    // 主线程执行持续循环任务
    main_loop();
    
    // 等待监听线程结束，避免资源泄漏
    pthread_join(input_thread, NULL);
    // 销毁互斥锁
    pthread_mutex_destroy(&exit_mutex);
    
    return 0;
}

关键细节说明 #

• 线程签名修正：check_input函数严格遵循pthread的函数签名要求，确保线程能正常创建和运行。
• 互斥锁同步：全局变量should_exit被主线程和监听线程同时访问，用互斥锁保证修改和读取操作的原子性，避免竞态问题。
• 线程等待：主线程调用pthread_join等待监听线程结束，确保所有资源都能正确释放。
• 阻塞处理：监听线程卡在getchar()，直到用户输入任意字符后才会修改退出标记，主线程的循环会实时检测这个标记并退出。

编译时记得链接pthread库：

gcc your_file.c -o your_program -lpthread

运行程序后，会不断输出循环计数，直到你按下任意键（加回车），程序就会正常退出啦！

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