编辑“︁C 语言线程池”︁（章节）

== 线程池实现 ==
以下是一个基本的C语言线程池实现（需要POSIX线程库支持）：

<syntaxhighlight lang="c">
#include <pthread.h>
#include <stdlib.h>
#include <stdio.h>

#define THREAD_NUM 4

typedef struct Task {
    void (*function)(void*);
    void* arg;
    struct Task* next;
} Task;

typedef struct ThreadPool {
    pthread_t threads[THREAD_NUM];
    Task* task_head;
    pthread_mutex_t mutex;
    pthread_cond_t cond;
    int shutdown;
} ThreadPool;

void* worker(void* arg) {
    ThreadPool* pool = (ThreadPool*)arg;
    while (1) {
        pthread_mutex_lock(&pool->mutex);
        while (pool->task_head == NULL && !pool->shutdown) {
            pthread_cond_wait(&pool->cond, &pool->mutex);
        }
        if (pool->shutdown) {
            pthread_mutex_unlock(&pool->mutex);
            pthread_exit(NULL);
        }
        Task* task = pool->task_head;
        pool->task_head = pool->task_head->next;
        pthread_mutex_unlock(&pool->mutex);
        task->function(task->arg);
        free(task);
    }
    return NULL;
}

ThreadPool* thread_pool_create() {
    ThreadPool* pool = (ThreadPool*)malloc(sizeof(ThreadPool));
    pool->task_head = NULL;
    pool->shutdown = 0;
    pthread_mutex_init(&pool->mutex, NULL);
    pthread_cond_init(&pool->cond, NULL);
    
    for (int i = 0; i < THREAD_NUM; ++i) {
        pthread_create(&pool->threads[i], NULL, worker, pool);
    }
    return pool;
}

void thread_pool_add_task(ThreadPool* pool, void (*function)(void*), void* arg) {
    Task* task = (Task*)malloc(sizeof(Task));
    task->function = function;
    task->arg = arg;
    task->next = NULL;
    
    pthread_mutex_lock(&pool->mutex);
    if (pool->task_head == NULL) {
        pool->task_head = task;
    } else {
        Task* current = pool->task_head;
        while (current->next != NULL) {
            current = current->next;
        }
        current->next = task;
    }
    pthread_cond_signal(&pool->cond);
    pthread_mutex_unlock(&pool->mutex);
}

void thread_pool_destroy(ThreadPool* pool) {
    pool->shutdown = 1;
    pthread_cond_broadcast(&pool->cond);
    for (int i = 0; i < THREAD_NUM; ++i) {
        pthread_join(pool->threads[i], NULL);
    }
    pthread_mutex_destroy(&pool->mutex);
    pthread_cond_destroy(&pool->cond);
    free(pool);
}
</syntaxhighlight>

=== 代码说明 ===
1. '''ThreadPool结构体'''：包含线程数组、任务队列头指针、互斥锁和条件变量
2. '''worker函数'''：工作线程的主循环，从队列获取并执行任务
3. '''thread_pool_create'''：初始化线程池并创建工作线程
4. '''thread_pool_add_task'''：向线程池添加新任务
5. '''thread_pool_destroy'''：安全关闭线程池