C语言实现线程池

要在 C 语言中实现线程池，您可以按照以下步骤进行：

步骤 1：定义线程池结构体

首先，定义一个结构体来表示线程池，包括线程池的属性和需要的数据结构。

typedef struct {
    pthread_t *threads; // 线程数组
    int thread_count; // 线程数量
    task_queue_t *task_queue; // 任务队列
    pthread_mutex_t lock; // 互斥锁
    pthread_cond_t task_available; // 条件变量，表示是否有任务可执行
    int is_shutdown; // 线程池关闭标志
} thread_pool_t;

步骤 2：定义任务队列结构体

接下来，定义一个结构体来表示任务队列，用于存储需要执行的任务。

typedef struct {
    task_t *tasks; // 任务数组
    int capacity; // 任务队列容量
    int size; // 当前任务数量
    int front; // 队头指针
    int rear; // 队尾指针
} task_queue_t;

步骤 3：定义任务结构体

定义一个结构体来表示要执行的任务。

typedef struct {
    void (*function)(void *arg); // 任务函数指针
    void *arg; // 任务参数
} task_t;

步骤 4：初始化线程池

编写函数来初始化线程池，创建线程数组，初始化互斥锁、条件变量等。

步骤 5：添加任务到任务队列

编写函数将任务添加到任务队列中，实现线程池的任务管理。

步骤 6：线程函数

编写函数作为线程的入口函数，用于从任务队列中获取任务并执行。

步骤 7：关闭线程池

编写函数来关闭线程池，等待所有任务执行完毕，释放资源。

代码示例

以下是一个简单的示例代码，展示了如何在 C 语言中实现一个基本的线程池：

// 线程池创建函数
thread_pool_t *thread_pool_create(int thread_count);

// 添加任务函数
void thread_pool_add_task(thread_pool_t *pool, void (*function)(void *), void *arg);

// 销毁线程池函数
void thread_pool_destroy(thread_pool_t *pool);

// 线程函数
void *thread_function(void *arg);

int main() {
    thread_pool_t *pool = thread_pool_create(4); // 创建包含4个线程的线程池

    // 添加任务到线程池
    for (int i = 0; i < 10; i++) {
        thread_pool_add_task(pool, task_function, task_arg);
    }

    // 销毁线程池
    thread_pool_destroy(pool);

    return 0;
}