pthread是否支持任务队列

pthread（POSIX Threads）本身并不直接支持任务队列

以下是一个简单的C语言示例，展示了如何使用pthread和队列实现一个简单的线程池：

#include<stdio.h>#include <stdlib.h>#include <pthread.h>#include <stdatomic.h>#define QUEUE_SIZE 10#define NUM_THREADS 4typedef struct Task {    void (*func)(void *);    void *arg;} Task;typedef struct TaskQueue {    Task queue[QUEUE_SIZE];    atomic_int head;    atomic_int tail;    pthread_mutex_t lock;    pthread_cond_t cond;} TaskQueue;typedef struct ThreadPool {    pthread_t threads[NUM_THREADS];    TaskQueue task_queue;} ThreadPool;void task_queue_init(TaskQueue *task_queue) {    task_queue->head = ATOMIC_VAR_INIT(0);    task_queue->tail = ATOMIC_VAR_INIT(0);    pthread_mutex_init(&task_queue->lock, NULL);    pthread_cond_init(&task_queue->cond, NULL);}void task_queue_push(TaskQueue *task_queue, Task task) {    pthread_mutex_lock(&task_queue->lock);    while ((task_queue->tail + 1) % QUEUE_SIZE == task_queue->head) {        pthread_cond_wait(&task_queue->cond, &task_queue->lock);    }    task_queue->queue[task_queue->tail] = task;    task_queue->tail = (task_queue->tail + 1) % QUEUE_SIZE;    pthread_cond_signal(&task_queue->cond);    pthread_mutex_unlock(&task_queue->lock);}Task task_queue_pop(TaskQueue *task_queue) {    pthread_mutex_lock(&task_queue->lock);    while (task_queue->tail == task_queue->head) {        pthread_cond_wait(&task_queue->cond, &task_queue->lock);    }    Task task = task_queue->queue[task_queue->head];    task_queue->head = (task_queue->head + 1) % QUEUE_SIZE;    pthread_cond_signal(&task_queue->cond);    pthread_mutex_unlock(&task_queue->lock);    return task;}void *thread_pool_worker(void *arg) {    ThreadPool *thread_pool = (ThreadPool *)arg;    while (1) {        Task task = task_queue_pop(&thread_pool->task_queue);        task.func(task.arg);    }    return NULL;}void thread_pool_init(ThreadPool *thread_pool) {    task_queue_init(&thread_pool->task_queue);    for (int i = 0; i < NUM_THREADS; i++) {        pthread_create(&thread_pool->threads[i], NULL, thread_pool_worker, thread_pool);    }}void thread_pool_add_task(ThreadPool *thread_pool, void (*func)(void *), void *arg) {    Task task = {.func = func, .arg = arg};    task_queue_push(&thread_pool->task_queue, task);}int main() {    ThreadPool thread_pool;    thread_pool_init(&thread_pool);    // 添加任务到线程池    for (int i = 0; i < 20; i++) {        thread_pool_add_task(&thread_pool, my_function, (void *)(intptr_t)i);    }    // 等待所有任务完成    // ...    return 0;}

这个示例中，我们创建了一个线程池，其中包含一个任务队列和四个工作线程。我们可以向线程池添加任务，这些任务将被工作线程从队列中取出并执行。注意，这个示例仅用于演示目的，实际应用中可能需要考虑更多细节，例如关闭线程池、处理错误等。