基于C语言Pthreads的HttpServer竞态条件调试难题

1. 栈上Task对象的生命周期错误 #

主线程while循环中定义的Task t是栈局部变量，每次循环迭代都会覆盖该变量内容。你将&t存入队列后，线程池取出这个地址时，对应的Task内容已被下一次循环的请求覆盖，甚至可能在栈帧失效后变成野指针，触发未定义行为（包括程序卡住、崩溃）。

修复代码：
主线程改用堆内存分配Task，确保生命周期覆盖线程执行过程：

while(true)
{
    int accept_socketfd = accept(socketfd, NULL, NULL);
    Task* t = malloc(sizeof(Task));
    t->task_function = &process_request;
    t->socket = accept_socketfd;
    t->logfile = audit_fd;
    queue_push(Q, t);
}

线程执行完任务后释放堆内存：

void* startThread(void* args)
{
    Sem_n_Queue* info = (Sem_n_Queue*)args;
    while(1)
    {
        Task* task_ptr;
        queue_pop(info->Q, (void**)&task_ptr);
        executeTask(task_ptr);
        free(task_ptr);
    }
}

2. Sem_n_Queue中错误复制sem_t对象 #

sem_t是操作系统管理的同步对象，不能直接赋值复制。你在info->semaphore = num_of_requests;中复制了栈上的信号量，导致线程函数使用的信号量与主线程实例不一致，sem_post无法唤醒线程的sem_wait，线程永久阻塞，最终队列被填满后主线程卡在queue_push的pthread_cond_wait上。

修复方案：
调整结构体定义，存储信号量指针：

typedef struct {
    sem_t* semaphore;
    queue_t* Q;
} Sem_n_Queue;

主线程中改为赋值指针：

sem_t num_of_requests;
sem_init(&num_of_requests, 0,0);
Sem_n_Queue* info = (Sem_n_Queue*)malloc(sizeof(Sem_n_Queue));
info->semaphore = &num_of_requests;
info->Q = Q;

3. 信号量与队列条件变量的冗余同步 #

你的队列已通过pthread_cond_t实现空/满同步，额外引入信号量会导致同步逻辑冲突：信号量计数与队列实际元素数量可能不一致，线程sem_wait后执行queue_pop时队列可能已为空，导致线程卡在queue_pop的等待中，主线程因队列满也卡住，形成死锁。

修复方案：
移除信号量，完全依赖队列本身的条件变量同步线程池：

• 删除主线程中sem_t num_of_requests相关代码
• 修改线程函数，去掉sem_wait，直接调用queue_pop（内部会等待队列非空）：

void* startThread(void* args)
{
    Sem_n_Queue* info = (Sem_n_Queue*)args;
    while(1)
    {
        Task* task_ptr;
        queue_pop(info->Q, (void**)&task_ptr);
        executeTask(task_ptr);
        free(task_ptr);
    }
}

4. queue_pop调用的类型错误 #

线程函数中Task task; queue_pop(info->Q, (void**)&task);是类型错误：&task是Task*，但queue_pop需要void**来接收指针类型元素。正确做法是用Task*指针接收队列中的元素地址。

修复后的线程函数：

void* startThread(void* args)
{
    Sem_n_Queue* info = (Sem_n_Queue*)args;
    while(1)
    {
        Task* task_ptr;
        queue_pop(info->Q, (void**)&task_ptr);
        executeTask(task_ptr);
        free(task_ptr);
    }
    return NULL;
}

关于pthread_join的位置优化 #

pthread_join放在主线程while(true)循环之后是正确的，但需要给主线程添加退出条件（比如捕获SIGINT信号），否则主线程永远不会执行到pthread_join。可以添加信号处理逻辑实现优雅退出：

volatile sig_atomic_t running = 1;

void handle_sigint(int sig) {
    running = 0;
    close(socketfd);
}

// 主线程初始化时注册信号处理
signal(SIGINT, handle_sigint);

// 修改主线程循环
while(running)
{
    int accept_socketfd = accept(socketfd, NULL, NULL);
    if(accept_socketfd == -1 && !running) {
        break;
    }
    Task* t = malloc(sizeof(Task));
    t->task_function = &process_request;
    t->socket = accept_socketfd;
    t->logfile = audit_fd;
    queue_push(Q, t);
}

// 等待线程池处理完剩余任务
for(int i = 0; i < threads; i++)
{
    if(pthread_join(th[i], NULL) != 0)
    {
        perror("Failed to join the thread");
    }
}
// 清理资源
queue_destroy(Q);
free(info);

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