如何在poll反复触发场景下实现未知数量线程的pthread_join操作

方案1：函数内部分配线程ID数组（匹配需等待所有线程结束的需求） #

你担心ID被覆盖的核心误区是误以为要把ID数组设为全局/静态变量，实际上完全可以把数组放在pollHandler的内部作用域，每次调用时根据本次的请求数动态创建，本次调用的数组和下一次调用完全独立，不存在覆盖问题。
你可以选择两种数组实现方式：

方式A：动态堆分配（兼容性最好，无栈溢出风险） #

int pollHandler(){
    int num_req = poll.size();
    // 本次调用独有的线程ID数组，仅本次调用生效
    pthread_t *tids = malloc(num_req * sizeof(pthread_t));
    if (tids == NULL) {
        return -1;
    }

    for(int i=0; i < num_req; i++){
        struct parameters *p = malloc(sizeof(struct parameters));
        // 此处补充给p成员赋值的逻辑
        if(pthread_create(&tids[i], NULL, thread_func, p) != 0){
            // 创建失败先释放已申请资源再返回
            free(tids);
            return -1;
        }
    }

    for(int i=0; i < num_req; i++){
        pthread_join(tids[i], NULL);
    }

    // 用完释放数组，不残留无效资源
    free(tids);
    return 0; 
}

方式B：C99可变长数组（代码更简洁） #

如果你的编译环境支持C99标准，可以直接用栈上可变长数组，不需要手动管理内存：

int pollHandler(){
    int num_req = poll.size();
    // 函数返回时自动释放，无需手动free
    pthread_t tids[num_req];

    for(int i=0; i < num_req; i++){
        struct parameters *p = malloc(sizeof(struct parameters));
        // 此处补充给p成员赋值的逻辑
        if(pthread_create(&tids[i], NULL, thread_func, p) != 0){
            return -1;
        }
    }

    for(int i=0; i < num_req; i++){
        pthread_join(tids[i], NULL);
    }

    return 0; 
}

方案2：分离线程（无需等待线程结束的异步场景可选） #

如果你不需要获取线程返回值，也可以在创建线程后直接设置线程分离，线程结束后系统自动回收资源，不需要维护ID数组也不需要调用pthread_join：

pthread_t tid;
if(pthread_create(&tid, NULL, thread_func, p) == 0){
    pthread_detach(tid);
}

这种方案的优势是pollHandler不需要等线程执行完就可以返回，能更快响应下一次poll()触发。

额外注意事项 #

• 你动态申请的struct parameters结构体，记得在线程函数执行结束时调用free释放，避免内存泄漏
• 如果单次请求数量非常大，不建议直接创建对应数量的线程，可以考虑用线程池限制最大并发数，避免系统资源耗尽

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