通过队列动态地将工作分配给 pthreads

Question

好的，我在将工作动态分配给队列中的 pthreads 时遇到问题。

例如，在我的代码中，我有一个如下所示的结构：

struct calc
{
    double num;
    double calcVal;
};

我将每个结构存储在长度为 l 的数组中，如下所示。

struct calc **calcArray; 

/* then I initialize the calcArray to say length l and 
   fill each calc struct with a num*/

现在，根据 num，我想找到 calcVal 的值。每个 struct calc 都有不同的 num 值。

我想生成 4 个 pthreads，这很容易，但我想在开始时让

线程 0 获取 calcArray[0]
线程 1 获取 calcArray[1]
线程 2 获取 calcArray[2]
线程 3 获取 calcArray[3]

现在假设每个线程执行每个 calc 的计算所需的时间不同，

如果线程 1 先完成，它将获取 calcArray[4]，

然后线程 3 完成并获取 calcArray [5] 执行

此操作，直到到达 calcArray[l] 的末尾。

我知道我可以将数组拆分为 l/4（每个线程获取四分之一的计算），但我不想这样做。相反，我想让工作像队列一样。关于如何做到这一点有什么想法吗？

Answer 1

您可以很容易地完成它，方法是创建一个包含要分配的下一个元素的索引的变量，然后用互斥体保护它。

示例：

// Index of next element to be worked on
int next_pos;

// Mutex that secures next_pos-access
pthread_mutex_t next_pos_lock;

int main() {
    // ...

    // Initialize the mutex before you create any threads 
    pthread_mutex_init(&next_pos_lock, NULL);

    next_pos = NUM_THREADS;

    // Create the threads

    // ...
}

void *threadfunc(void *arg) {
    int index = ...;

    while (index < SIZE_OF_WORK_ARRAY) {
        // Do your work

        // Update your index
        pthread_mutex_lock(&next_pos_lock);
        index = next_pos;
        next_pos++;
        pthread_mutex_unlock(&next_pos_lock);
    }
}

另请参阅：POSIX 线程编程 - 互斥变量