0

当我使用 pthread_join() 时，我不确定它是否在正确的位置。就像现在一样，它会在再次迭代循环之前等待线程退出吗？我想我要问的是我应该将它从双 for 循环中取出并在 pthread_join() 之后直接创建一个新的 for 循环吗？

PS：我对一般线程和 C 语言非常陌生。我还有另一个关于释放 malloc 东西的问题（在代码中作为注释）。我不确定在哪里使用 free 关键字，因为 malloc 结果指针在内部 for 循环的每次迭代后都消失了。

这是我的代码。它用于在两个预定义矩阵 (A&B) 上进行矩阵乘法。（这就是老师希望我们这样做的方式）。

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

#define M 3 
#define K 2  
#define N 3 

int A[M][K] = {{1,4}, {2,5}, {3,6}}; 
int B[K][N] =  {{8,7,6}, {5,4,3}}; 
int C[M][N]; 

struct coords 
{ 
    int  i ;  /*  row  */       
    int  j ;  /*  column  */ 
}; 

//thread function
void* calc_val(void* resultCoords)
{
    int n, result = 0;
    struct coords **matCoords = (struct coords**) resultCoords;
    for(n = 0; n < K; n++)
    {
        result += A[(*matCoords)->i][n] * B[n][(*matCoords)->j];
    }
    C[(*matCoords)->i][(*matCoords)->j] = result;
    // One more question: 
    // <- Should I free mem from malloc here? 
}

int main(int argc, char** argv) 
{
    int numThreads = M * N, threadIndex = 0, i, j;
    pthread_t threads[numThreads];
    pthread_attr_t attributes[numThreads];
    for (i = 0; i < M; i++)
    {
        for(j = 0; j < N; j++)
        {
            struct coords *data = (struct coords*)malloc(sizeof(struct coords));
            data->i = i;
            data->j = j;
            pthread_attr_init(&attributes[threadIndex]);
            pthread_create(
                    &threads[threadIndex],
                    &attributes[threadIndex],
                    calc_val, 
                    &data);
            pthread_join(threads[threadIndex], NULL); // <-Main Question
            threadIndex++;
        }
    }

    /* ... */

    return (EXIT_SUCCESS);
}
4

1 回答 1

0

在您的代码中，您基本上执行以下操作：

  1. 为线程准备一些数据
  2. 运行线程
  3. 等它完成
  4. 进入下一次迭代

所以这段代码绝对是顺序的

为了使它不连续，你需要这样的东西：

  1. 准备一些数据
  2. 运行线程
  3. 进入下一次迭代
  4. 等到所有线程都完成

尝试这样的事情：

   for (i = 0; i < M; i++)
   {
        for(j = 0; j < N; j++)
        {
            struct coords *data = (struct coords*)malloc(sizeof(struct coords));
            data->i = i;
            data->j = j;
            pthread_attr_init(&attributes[threadIndex]);
            pthread_create(&threads[threadIndex], &attributes[threadIndex], calc_val, &data);
            threadIndex++;
        }
    }
    for (i=0;i<numThreads;i++)
        pthread_join(threads[i], NULL);

关于内存分配的下一个问题 - 您可以在所有线程完成时执行此操作（然后您需要将所有分配的指针存储在某处），或者您可以按照评论中的要求在每个线程中释放它

于 2013-10-12T00:15:45.180 回答