5

我有一个 C 语言程序。

我使用 pthread_create 创建了 3 个线程，并且创建了一个互斥锁以锁定/解锁关键区域。

pthread_create的第三个参数是指向线程将执行的函数的指针。

在我在网上找到的示例中，这个函数 总是非常简单，例如打印线程 id 或打印消息。

当线程要执行的函数包含一个for 循环时会发生什么？

因为在我的程序中，我希望每个线程都使用二维数组。

每个线程应找到二维数组中一行的总和。例如

Thread1应计算二维数组的第一行之和

Thread2计算第二行的总和
Thread1计算第三行的总和
Thread3计算第三行的总和

我不关心线程的顺序，但我需要每个线程都选择其中的一行。

我有以下代码将二维数组中的两个单元格相加。

该程序：

  1. 创建 NTHREADS

     for(i=0; i < NTHREADS; i++)
    {
       pthread_create( &thread_id[i], NULL, CalculateSum, NULL );
    }

  2. 每个线程等待其他线程完成

    for(j=0; j < NTHREADS; j++)
   {
      pthread_join( thread_id[j], NULL);
   }

  3. 每个线程应执行的函数，但对于数组的一行而不是整个数组是

    void *CalculateSum(void *dummyPtr)
{
   pthread_mutex_lock( &mutex1 );

 int i,j,sum = 0;

  for( i = 0; i <= N-1; i++) {
        for( j = 0; j <= M-1; j++) {
                sum = dimensional_array[i][j] + dimensional_array[i][j];
        }
         printf(" Sum = %d\n", sum);
        }

   counter++;

   pthread_mutex_unlock( &mutex1 );
}

整个程序如下： 程序没有任何编译错误。

为了运行它，你应该这样做：gcc -pthread program.c

    //program.c

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

   #define NTHREADS 3
   void *CalculateSum(void *);
   pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
   int  counter = 0;

   #define N 10
   #define M 10

   int dimensional_array[N][M];

   main()
   {
      pthread_t thread_id[NTHREADS];
      int i, j;

      for (i = 0; i <= N - 1; i++ )
           for( j = 0; j <= M - 1; j++)
                   dimensional_array[i][j] = i;

      for(i=0; i < NTHREADS; i++)
      {
         pthread_create( &thread_id[i], NULL, CalculateSum, NULL );
      }

      for(j=0; j < NTHREADS; j++)
      {
         pthread_join( thread_id[j], NULL);
      }



      printf("Final counter value: %d\n", counter);

      //print ARRAY
      for (i = 0; i <= N-1; i++ ) {
           for( j = 0; j <= M-1; j++)
                   printf("%d\t",dimensional_array[i][j]);
           printf("\n");
           }
   }
   //Calculate
   void *CalculateSum(void *dummyPtr)
   {
      pthread_mutex_lock( &mutex1 );

    int i,j,sum = 0;

     for( i = 0; i <= N-1; i++) {
           for( j = 0; j <= M-1; j++) {
                   sum = dimensional_array[i][j] + dimensional_array[i][j];
           }
            printf(" Sum = %d\n", sum);
           }

      counter++;

      pthread_mutex_unlock( &mutex1 );
   }

所以，我希望每个线程都能找到一行的总和，但我很困惑，我不知道该怎么做。

在我的程序中，每次线程调用计算函数时，都会计算所有行的总和，而不仅仅是一个

[注意：为简单起见，我将第一个元素与它自己的元素相加，重点是了解这些线程如何全部发生在那个 for 循环中]

如果有人可以帮助我，我会很高兴

提前致谢

4

2 回答 2

6

您应该创建一个每个线程参数的数组，并将这些参数一个接一个地传递给线程。在您的情况下，单个指针int就足够了：您将其索引threadindex从零传递给线程到NTHREADS，并且线程将总和传递回这样的行row % NTHREADS == threadindex。

这是您的线程函数的外观：

void *CalculateSum(void *args)
{
    int *argPtr = args;

    int i,j,sum = 0;
    int threadindex = *argPtr;

    for( i = 0; i <= N-1; i++) {
        if (i % NTHREADS != threadindex) continue;
        for( j = 0; j <= M-1; j++) {
            sum += dimensional_array[i][j];
        }
    }

    pthread_mutex_lock( &mutex1 ); Mutex must go here
    counter++;
    pthread_mutex_unlock( &mutex1 );
    // Pass the value back:
    *argPtr = sum;
}


main()
{
    pthread_t thread_id[NTHREADS];
    int thread_args[NTHREADS];
    int i, j;

    pthread_mutex_init(&mutex1, NULL);

    for (i = 0; i <= N - 1; i++ )
        for( j = 0; j <= M - 1; j++)
            dimensional_array[i][j] = i;

    for(i=0; i < NTHREADS; i++)
    {
        thread_args[i] = i;
        pthread_create( &thread_id[i], NULL, CalculateSum, &thread_args[i]);
    }

    int sum = 0;
    for(j=0; j < NTHREADS; j++)
    {
        pthread_join( thread_id[j], NULL);
        sum += thread_args[i];
    }

    printf("Final counter value: %d. Total: %d\n", counter, sum);
}
于 2012-11-16T18:48:09.470 回答
3

计算一行的总和（忽略线程的东西）：

void *CalculateSum(void *dummyPtr)
{
    int j,sum = 0;

    int i = (int)dummyPtr;
    for( j = 0; j <= M-1; j++) {
        sum += dimensional_array[i][j];
    }
    printf(" Sum = %d\n", sum);

    pthread_mutex_lock( &mutex1 );
    counter++;
    pthread_mutex_unlock( &mutex1 );
}

然后像这样创建线程：

int line_number = 2;    // Or whatever line to print`enter code here`
pthread_create( &thread_id[i], NULL, CalculateSum, (void *)line_number );

编辑：把“counter++”放回去。

于 2012-11-16T18:45:36.840 回答