2

我对 C 很陌生，如果这个问题很离谱，我很抱歉。我已经使用 Java 执行器服务来制作固定的线程池，并且无法理解如何在 C 中做类似的事情。

我学会了如何使用 pthreads 在 c 中创建线程（这似乎很容易），但我不确定如何创建一个固定数量的线程消耗的队列？到目前为止，我所做的所有教程要么自行在主语句中启动线程，要么在 for 循环中执行。如果我采用这种方法，那么当我想要的只是 3 或 4 个线程并让它们处理队列时，我将拥有数百万个线程（每个工作项 1 个）。

这可能吗？如果可以，我需要学习什么？如果 pthreads 无法实现，那么我很乐意使用其他东西，我正在 Mac 上开发并将其部署在 linux 上。

4

1 回答 1

2

您可以通过使用条件变量轻松地使用单生产者/多消费者模型来做到这一点。请记住，这是一种架构，其他架构当然是可能的。

在主线程中，您只需创建队列、互斥锁和条件变量，然后启动任意数量的线程运行，伪代码如：

glbQueue = []
glbMutex = new mutex
glbCondVar = new condvar
for i = 1 to 10:
    start thread using thrdFn

下一步是将您需要的任何工作项添加到队列中（使用互斥锁）并根据需要启动条件变量以唤醒线程：

while workitem = getNextWorkItem():
    lock glbMutex
    glbQueue.append (workItem)
    kick glbCondVar
    unlock glbMutex

一旦所有工作项完成，您等待队列清空，然后发布一些哨兵项目以关闭线程，然后等待它们完成后再退出。

lock glbMutex
while glbQueue is not empty:
    kick glbCondVar
    unlock glbMutex.
    sleep for a bit
    lock glbMutex
unlock glbMutex.

for i = 1 to 10:
    lock glbMutex
    glbQueue.append (endWorkItem)
    kick glbCondVar
    unlock glbMutex.
    wait for any one thread to exit
exit

完成工作的线程也相对简单。首先，它们在无限循环中运行，等待条件变量被踢出。在该循环中，他们处理工作项，直到没有更多可用项，然后他们重新进入睡眠状态。

一旦线程接收到最终工作项，它就会退出，从而保证每个线程都获得一个最终项。

换句话说，类似：

initialise
stillGoing = true
lock glbMutex
while stillGoing:
    wait on glbCondVar using glbMutex
    while stillGoing and glbQueue is not empty:
        extract workItem from glbQueue to thread local storage
        unlock glbMutex.
        if workItem is endWorkItem:
            stillGoing = false
        else:
            do the work specified by workItem
        lock glbMutex
unlock glbMutex
clean up
exit thread

这基本上允许您在队列上拥有固定数量的线程处理项目，并且队列本身受到互斥锁的保护，因此工作线程或主线程之间没有争用。

于 2012-09-03T08:50:28.350 回答