c - 如何使用带 pthreads 的线程池？

Question

我有一个作业队列，我想创建一个包含四个线程的池，我可以将作业放入其中。我所坚持的是如何制作线程并在没有工作时让它们暂停。

JOB QUEUE        | job1 | job2 | job3 | job4 | ..

THREAD POOL      | thread1 | thread2 | thread3 | thread4 |

要创建我当前在初始化点的线程:

for (t=0; t<num_of_threads; t++){
    pthread_create(&(threads[t]), NULL, doSth2, NULL);
}

其中 num_of_threads=4 和 doSth2 是一个内部没有任何内容的函数。因此，一旦我创建了 4 个线程并使用 doSth2 完成了它们，我如何才能在不杀死它们的情况下给它们新的工作呢？

Answer 1

线程池的关键是队列。以下是我开发的线程池的修改函数。

将元素放入队列

void queue_add(queue q, void *value)
{
    pthread_mutex_lock(&q->mtx);

    /* Add element normally. */

    pthread_mutex_unlock(&q->mtx);

    /* Signal waiting threads. */
    pthread_cond_signal(&q->cond);
}

从队列中获取元素

void queue_get(queue q, void **val_r)
{
    pthread_mutex_lock(&q->mtx);

    /* Wait for element to become available. */
    while (empty(q))
        rc = pthread_cond_wait(&q->cond, &q->mtx);

    /* We have an element. Pop it normally and return it in val_r. */

    pthread_mutex_unlock(&q->mtx);
}