3

因此，当我运行我的代码时，我在 pthread_join 处遇到了分段错误。在我的 pthread_join 之后有一个打印语句没有运行。有谁知道为什么？你能给我一些关于如何解决这个问题的提示或想法吗？

输出打印出我的矩阵的所有行号，直到结束，然后它离开 matrixCalc 函数并打印“创建线程后”。当我为 1 个线程输入参数时，就会发生这种情况。

我在这里包含了一小部分代码：

int main(int argc, char*argv[]) 
{
  //takes in number of threads as 1st arg
  pthread_attr_init(&attr);
  //initialize matrix here

  //passes num of threads through matrixcalc
  for(i = 0; i < numberOfThreads; i++)
    {
      threadCount++;
      pthread_create(&tid, &attr, matrixCalc(threadCount), NULL);  
    }
  printf("after threads are created\n");
  pthread_join(tid, NULL);  
  printf("after join\n");
  exit(0);
  return 0;
}

这是矩阵计算函数：

    void *matrixCalc(threadCount) 
{
  int i, j, sum, tempNum, currentRow;
  currentRow = threadCount;
  sum=0;

  while(currentRow < 1200)
    {
      //cycles through the column j for matrix B
      for(j=0; j<500; j++)
        {
          //cycles through the diff i values for the set row in matrix A and column in matrix B
          for(i=0; i<1000; i++)
            {
              //Matrix A set i value is at threadcount-1
              //Matrix B i value = j
              //Matrix B j value = i
              //Multiply together and add to sum
              tempNum = (matrixA[currentRow-1][i])*(matrixB[i][j]);
              sum = sum+tempNum;
            }
          //Set Matrix C at i value = currentRow and jvalue = i to sum
          matrixC[currentRow-1][j] = sum;
          //printf("%d\n", matrixC[currentRow-1][i]);
        }
        //increase threadcount by number of threads 
        //until you hit max/past max val
        currentRow = currentRow + nThreads;
        //printf("%d\n", currentRow);
    }
    return NULL;

}
4

2 回答 2

8

调用pthread_create()时需要传递类型函数的地址void *(*)(void *)。代码所做的是在那里调用一个函数，以便将其结果传递给pthread_create().

更改此行

pthread_create(&tid, &attr, matrixCalc(threadCount), NULL);

成为

pthread_create(&tid, &attr, matrixCalc, NULL);

或者

pthread_create(&tid, &attr, &matrixCalc, NULL);

这实际上是相同的。

如上所述，线程函数需要声明为void *(*)(void *).

所以改变这个

 void *matrixCalc(threadCount)

会变成这样

 void * matrixCalc(void *)

由于代码似乎试图产生多个线程，并且所有线程都应该加入perpare空间来存储几个pthread-id。

例如，这可以使用这样的数组来完成：

pthread_t tid[numberOfThreads] = {0};

然后像这样创建线程：

pthread_create(&tid[i], &attr, matrixCalc, NULL);

要将线程号（计数器i）向下传递给线程，还可以通过定义给它空间

int thread_counts[numberOfThreads] = {0};

分配它并将其作为线程创建时的第 4个参数传递：

 thread_counts[i] = i;
 pthread_create(&tid[i], &attr, matrixCalc, &thread_Counts[i]);

在线程函数中向下然后通过修改得到它

void *matrixCalc(threadCount) 
{
  int i, j, sum, tempNum, currentRow;
  currentRow = threadCount;
  ...

像这样：

void * matrixCalc(void * pv) 
{
  int i, j, sum, tempNum, currentRow;
  currentRow = *((int*) pv);
  ...

最后加入所有线程，pthread_join()用循环替换单个调用：

for (i = 0; i < numberOfThreads; ++i)
{
  pthread_join(tid[i], NULL);  
}
于 2013-11-25T19:09:32.073 回答
1

int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void * (*start_routine) (void *), void *arg);

第三个参数是一个 start 函数，它接受一个 void ptr 并返回一个 void ptr。

第四个参数采用指向您要传递的数据的 void ptr，在本例中为 threadcnt。

于 2013-11-25T18:48:35.123 回答