C语言优先级线程池任务返回值处理方案咨询

你提出的双入队函数方案完全可行，能精准区分“需要返回值”和“无需返回值”的场景，从根源上避免了统一存储返回值带来的队列膨胀和内存浪费问题。不过可以针对细节做优化，同时也有更通用的替代方案：

你的方案优化点 #

针对future_ret_t结构体的设计，建议包含以下核心字段：

typedef struct future_ret {
    pthread_mutex_t mutex;
    pthread_cond_t cond;
    int completed; // 任务完成标记：0未完成，1已完成
    void *ret_val; // 任务返回值
} future_ret_t;

• 用户调用enqueue_task_kret拿到指针后，可通过pthread_cond_wait等待任务完成，无需轮询；
• 线程工作函数执行完任务后，需加锁更新completed标记和ret_val，再调用pthread_cond_signal唤醒等待的用户线程；
• 务必提供配套的销毁函数（比如void free_future(future_ret_t *f)），让用户在获取结果后释放资源，避免内存泄漏。

对于enqueue_task_dret，线程执行完任务后直接丢弃返回值，无需任何额外存储，完全符合无返回值场景的性能需求。

更通用的替代方案：回调式处理 #

可以合并为单个入队函数，通过传入结果回调函数来灵活处理返回值，无需维护两个入队接口：

// 定义结果回调函数类型
typedef void (*task_result_cb)(void *ret_val, void *cb_args);

// 统一入队函数
void enqueue_task(void *(task_fn)(void *), void *args, int priority, task_result_cb result_cb, void *cb_args);

• 若用户无需返回值，传入NULL作为result_cb，线程执行完任务直接丢弃返回值；
• 若需要处理返回值，传入自定义回调函数，线程任务执行完毕后直接调用该回调，将返回值和用户传入的回调参数一起传递，实现异步结果处理；
• 这种方案无需额外的返回值队列或future结构体，内存开销更低，异步性更强，也是不少成熟线程池采用的设计思路。

通用注意事项 #

不管采用哪种方案，任务结构体中都要增加一个标记（比如int need_ret），线程工作函数根据该标记判断后续处理逻辑：

• 标记为0：直接丢弃返回值；
• 标记为1：存储到future_ret_t或调用回调函数。
  同时要做好同步原语的保护，避免多线程访问时的竞态条件。

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