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

Answer 2

作为nicutar回答的另一种重复，您可以使用POSIX消息队列，它将处理内核中的同步问题。系统调用会有一些小的开销，这可能是一个问题，也可能不是。这是相当小的，因为内核做了所有你必须手动做的事情。

消费者线程可以阻塞mq_receive，如果您创建一个特殊类型的队列消息，它可以很容易地告诉线程何时关闭。