C语言线程池原理详解 | c语言线程池原理 - c 语言线程池原理及周边知识全景解析

大核心流程

风险隔离优势

假设无线程池，5个线程直接操作全局队列：

• 线程A写入数据时，线程B同时读取 → 数据错乱
• 线程C崩溃 → 可能导致全局队列指针失效 → 全局崩溃

使用线程池后：

• 每个任务独立参数（结构体传参），避免全局变量污染
• 任务执行在独立栈空间，一个任务崩溃不影响其他线程
• 队列访问由锁保护（pthread_mutex_lock），确保原子操作

核心数据结构

typedef struct task {
    void (function)(void arg);  // 任务函数指针
    void arg;                     // 参数指针
    struct task next;            // 链表指针
} task_t;
typedef struct {
    task_t head;         // 任务队列头指针
    task_t tail;         // 任务队列尾指针
    int thread_count;     // 当前线程数
    int max_threads;      // 最大线程数
    int min_threads;      // 最小线程数
    int idle_threads;     // 空闲线程数
    pthread_mutex_t lock; // 互斥锁
    pthread_cond_t notify; // 条件变量
    int shutdown;         // 退出标志
} thread_pool_t;

线程工作主循环

void worker(void arg) {
    thread_pool_t pool = (thread_pool_t )arg;
    while (1) {
        pthread_mutex_lock(&pool->lock);
        // 若队列为空且未 shutdown，则等待
        while (!pool->head && !pool->shutdown) {
            pool->idle_threads++;
            pthread_cond_wait(&pool->notify, &pool->lock);
            pool->idle_threads--;
        }
        if (pool->shutdown) {
            pthread_mutex_unlock(&pool->lock);
            break;
        }
        // 取出任务
        task_t task = pool->head;
        pool->head = task->next;
        if (!pool->head) pool->tail = NULL;
        pthread_mutex_unlock(&pool->lock);
        // 执行任务（脱离锁保护，避免阻塞其他线程）
        task->function(task->arg);
        free(task);
    }
    return NULL;
}

任务提交伪代码

int thread_pool_add_task(thread_pool_t pool, void (func)(void ), void arg) {
    task_t task = malloc(sizeof(task_t));
    task->function = func;
    task->arg = arg;
    task->next = NULL;
    pthread_mutex_lock(&pool->lock);
    if (pool->shutdown) {
        free(task);
        pthread_mutex_unlock(&pool->lock);
        return -1;
    }
    // 添加到队列尾
    if (!pool->head) {
        pool->head = task;
        pool->tail = task;
    } else {
        pool->tail->next = task;
        pool->tail = task;
    }
    // 唤醒空闲线程
    pthread_cond_signal(&pool->notify);
    pthread_mutex_unlock(&pool->lock);
    return 0;
}

阶段动态策略

阶段	触发条件	响应动作
扩容	队列长度 > 线程数 × 2 且线程数 < max_threads	创建新线程（每次+1）
缩容	空闲线程持续60秒且线程数 > min_threads	销毁1个线程
拒绝策略	队列满且线程数已达max_threads	丢弃任务/阻塞/回调通知

struct timespec ts;
clock_gettime(CLOCK_REALTIME, &ts);
ts.tv_sec += 60; // 超时60秒
if (!pool->head && !pool->shutdown) {
    pthread_cond_timedwait(&pool->notify, &pool->lock, &ts);
}

种分发策略对比

策略	原理	适用场景
随机分发	任务随机分配给线程	任务耗时均匀、无状态依赖
轮询分发	按顺序循环分配任务	任务量大、负载均衡性要求高
亲和性分发	任务绑定特定CPU核心	缓存敏感型任务（如高频数据处理）