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 4

typedef 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;
}

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