Pthreads程序实现任务队列

**任务队列（Task Queue）程序实现**
=====================================在多线程编程中，任务队列是非常重要的概念。它允许我们将任务放入一个队列中，然后由线程从队列中取出并执行。这篇文章将介绍如何使用Pthreads库来实现一个简单的任务队列程序。

**任务队列结构**
----------------我们的任务队列将使用一个链表结构来存储任务。每个任务都将包含一个指向任务函数的指针，以及一个用于传递参数的void*类型的指针。

ctypedef struct task {
 void (*func)(void*);
 void* arg;
 struct task* next;
} Task;

**任务队列函数**
-----------------

我们的任务队列将提供以下几个函数：

* `task_queue_init`: 初始化任务队列。
* `task_queue_add`: 将任务添加到任务队列中。
* `task_queue_remove`: 从任务队列中取出并执行一个任务。
* `task_queue_destroy`: 销毁任务队列。

cvoid task_queue_init(Task** queue) {
 *queue = NULL;
}

int task_queue_add(Task** queue, void (*func)(void*), void* arg) {
 Task* new_task = malloc(sizeof(Task));
 if (new_task == NULL) return -1;

 new_task->func = func;
 new_task->arg = arg;
 new_task->next = *queue;
 *queue = new_task;

 return0;
}

int task_queue_remove(Task** queue, void (*func)(void*)) {
 Task* current = *queue;
 if (current == NULL) return -1;

 while (current != NULL && current->func != func) {
 Task* next = current->next;
 free(current);
 current = next;
 }

 if (current == NULL) return -1;

 Task* next = current->next;
 free(current);

 *queue = next;

 return0;
}

void task_queue_destroy(Task** queue) {
 while (*queue != NULL) {
 Task* next = (*queue)->next;
 free(*queue);
 *queue = next;
 }
}

**线程函数**
-------------

我们的线程将从任务队列中取出一个任务，并执行它。

cvoid* thread_func(void* arg) {
 TaskQueue* queue = (TaskQueue*)arg;

 while (1) {
 int ret = task_queue_remove(&queue->tasks, NULL);
 if (ret == -1) break;

 void (*func)(void*) = get_task_function(queue->tasks);
 func(get_task_arg(queue->tasks));
 }

 return NULL;
}

**主函数**
----------

我们的主函数将创建一个任务队列，添加几个任务，然后启动线程。

cint main() {
 TaskQueue queue;

 task_queue_init(&queue.tasks);

 int ret = task_queue_add(&queue.tasks, func1, arg1);
 if (ret == -1) return1;

 ret = task_queue_add(&queue.tasks, func2, arg2);
 if (ret == -1) return1;

 pthread_t thread;
 pthread_create(&thread, NULL, thread_func, &queue);

 // 等待线程结束 pthread_join(thread, NULL);

 task_queue_destroy(&queue.tasks);

 return0;
}

**总结**
----------

在本文中，我们实现了一个简单的任务队列程序，使用Pthreads库来管理任务。我们提供了几个函数来初始化、添加和取出任务，以及销毁任务队列。线程函数从任务队列中取出一个任务，并执行它。主函数创建一个任务队列，添加几个任务，然后启动线程。

**注意**
--------

本文中的代码仅供参考，请自行测试和调试以确保其正确性和安全性。