向线程传递来自 for 循环的值

Question

我正在尝试创建线程并将来自 for 循环的值传递给每个线程。这是代码段

pthread_t *threadIDs;
    int i = 0;
    if(impl == 1)
    {
        threadIDs = (pthread_t *)malloc(sizeof(pthread_t)*reduces);
        for(;i < reduces; i++)
        {
            pthread_create(&threadIDs[i], NULL, reduce,&i);
        }
    }

它没有传递正确的循环值，这是有道理的，因为我正在创建一个竞争条件。从循环中传递 i 的正确值的最简单方法是什么？

另一个问题，每个线程会在下一个线程被创建和调用之前完成执行吗？

Answer 1

您已经动态创建了一个线程 ID 数组。对要传入的值执行相同操作。

pthread_t *threadIDs;
int *values;
int i = 0;
if(impl == 1)
{
    threadIDs = malloc(sizeof(pthread_t)*reduces);
    values = malloc(sizeof(int)*reduces);
    for(;i < reduces; i++)
    {
        values[i] = i;
        pthread_create(&threadIDs[i], NULL, reduce, &values[i]);
    }
}

每个线程将使用不同的数组成员，因此不存在竞争条件。

Answer 2

您可以定义一个结构并将 i 分配给对象的变量。

#include <stdio.h>
#include <pthread.h>

typedef struct Param_ {
    int index;
}Param;

static void* thread(void* p) {
    Param* param = p;
    printf("index: %d\n", param->index);
}

int main() {
    int i = 0;
    int reduces = 10;
    pthread_t *threadIDs;

    threadIDs = (pthread_t *)malloc(sizeof(pthread_t)*reduces);
    for(; i < reduces; i++)
    {
        Param* p;
        p = (Param*)malloc(sizeof(*p));
        p->index = i;
        pthread_create(&threadIDs[i], NULL, thread, p);
    }

    return 0;
}

Answer 3

从我的循环中传递 i 的正确值的最简单方法是什么？

什么被认为是“简单”取决于用例，所以这里有另一种方法来解决您提出的问题：

#include <pthread.h>

pthread_mutex_t m_init;
pthread_cond_t c_init;

int init_done = 1;

void* thread_function(void * pv)
{
  pthread_mutex_lock(&m_init);

  size_t i = *((size_t*) pv);
  init_done = 1;

  pthread_cond_signal(&c_init);

  pthread_mutex_unlock(&m_init);

  ...
}

#define THREADS_MAX (42)

int main(void)
{
  pthread_t thread[THREADS_MAX];

  pthread_mutex_init(&m_init, NULL);
  pthread_cond_init(&c_init, NULL);

  for(size_t i = 0; i < THREADS_MAX; ++i)
  {
    pthread_mutex_lock(&m_init);

    init_done = 0;
    pthread_create(&thread[i], NULL, thread_function, &i);

    while (!init_done)
    {
      pthread_cond_wait(&c_init);
    }

    pthread_mutex_unlock(&m_init);
  }

  ...
}

^{（为了便于阅读，省略了错误检查）}