籽毛毛 2019-05-14 01:25 采纳率: 100%
浏览 803
已采纳

N阶矩阵乘法的并行线程化,创建k个线程,分别计算N/k行,存到同一数组,出错求助(Linux多线程编程)

N阶矩阵相乘并线线程化

比如8阶矩阵相乘,创建2个线程,则一个线程算1-4行,另一个线程算5-8行,然后存到同一个数组里。

每次运行的结果有些行数全为0,请问是线程不安全吗?可是两个线程操作的是同一数组的不同行数,按道理是线程安全啊?

Linux系统运行,编译命令:gcc -o 文件名 文件名.c -lpthread

运行命令:./文件名 线程数

代码如下:

#include <pthread.h>
#include <sys/time.h>
#include <stdio.h>
#include <stdlib.h>
#define N 8
int a[N][N], b[N][N],c[N][N],each;

void *sum(void *vargp);

int main(int argc, char **argv)
{
    pthread_t tid[N];
    int i,j,begin=0, nthreads,temp[N][N];

    /*Get input arguments */
    if (argc != 2) {
        printf("Usage: %s <nthreads>\n", argv[0]);
        exit(0);
    }
    nthreads = atoi(argv[1]);   //线程数

    //生成0-100随机数、初始化矩阵a,b
    srand((int)time(NULL)); //生成时间种子
    for (i = 0; i<N; i++)
        for (j = 0; j<N; j++)
        {
            a[i][j] = ((rand() % 10) + 1);
            b[i][j] = ((rand() % 10) + 1);
            c[i][j] = 0;
        }

    each = N / nthreads;    //每个线程处理each行

    for (i = 0; i < nthreads; i++) {
        pthread_create(&tid[i], NULL, sum, (void*)&begin);
        begin += each;
    }
    for (i = 0; i < nthreads; i++)
        pthread_join(tid[i], NULL);

    //输出a矩阵
    for (i = 0; i < N; i++)
    {
        for (j = 0; j < N; j++)
        {
            printf("%5d", a[i][j]);
        }
        printf("\n");
    }
    printf("\n");

    //输出b矩阵
    for (i = 0; i < N; i++)
    {
        for (j = 0; j < N; j++)
        {
            printf("%5d", b[i][j]);
        }
        printf("\n");
    }
    printf("\n");

    //输出c矩阵
    for (i = 0; i < N; i++)
    {
        for (j = 0; j < N; j++)
        {
            printf("%5d", c[i][j]);
        }
        printf("\n");
    }

    exit(0);
}

void *sum(void* argp)
{
    int begin = *((int*)argp);
    int end = begin + each  ;
    int i,j,m;

    for (i = begin; i < end; i++)
        for (j = 0; j < N; j++)
            for(m=0;m<N;m++)
            { 
                c[i][j] += a[i][m] * b[m][j];
            }
    return NULL;
}

图片说明
图片说明

  • 写回答

2条回答 默认 最新

  • 籽毛毛 2019-05-14 19:55
    关注

    终于找到问题了,创建线程时的传参出错了,线程还没来得及保存传来的参数,参数就自增了(传递的是指针)

    修改后的代码如下

    #include <pthread.h>
    #include <sys/time.h>
    #include <stdio.h>
    #include <stdlib.h>
    #define N 4
    int a[N][N], b[N][N],c[N][N],each;
    
    void *sum(void *vargp);
    
    int main(int argc, char **argv)
    {
        pthread_t tid[N];
        int i,j,begin[N], nthreads,temp[N][N];
    
        /*Get input arguments */
        if (argc != 2) {
            printf("Usage: %s <nthreads>\n", argv[0]);
            exit(0);
        }
        nthreads = atoi(argv[1]);   //线程数
    
        //生成0-100随机数、初始化矩阵a,b
        srand((int)time(NULL)); //生成时间种子
        for (i = 0; i<N; i++)
            for (j = 0; j<N; j++)
            {
                a[i][j] = ((rand() % 10) + 1);
                b[i][j] = ((rand() % 10) + 1);
                c[i][j] = 0;
            }
    
        each = N / nthreads;    //每个线程处理each行 
    
        for (i = 0; i < nthreads; i++){
            begin[i]=i*each;
        }
    
        for (i = 0; i < nthreads; i++) {
            pthread_create(&tid[i], NULL, sum, (void*)&begin[i]);
        }
    
        for (i = 0; i < nthreads; i++)
            pthread_join(tid[i], NULL);
    
        //输出a矩阵
        for (i = 0; i < N; i++)
        {
            for (j = 0; j < N; j++)
            {
                printf("%5d", a[i][j]);
            }
            printf("\n");
        }
        printf("\n");
    
        //输出b矩阵
        for (i = 0; i < N; i++)
        {
            for (j = 0; j < N; j++)
            {
                printf("%5d", b[i][j]);
            }
            printf("\n");
        }
        printf("\n");
    
        //输出c矩阵
        for (i = 0; i < N; i++)
        {
            for (j = 0; j < N; j++)
            {
                printf("%5d", c[i][j]);
            }
            printf("\n");
        }
    
        exit(0);
    }
    
    void *sum(void* argp)
    {
        int begin = *((int*)argp);
        int end = begin + each  ;
        int i,j,m;
    
        for (i = begin; i < end; i++)
            for (j = 0; j < N; j++)
                for(m=0;m<N;m++)
                { 
                    c[i][j] += a[i][m] * b[m][j];
                }
        return NULL;
    }
    

    图片说明

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 电力市场出清matlab yalmip kkt 双层优化问题
  • ¥30 ros小车路径规划实现不了,如何解决?(操作系统-ubuntu)
  • ¥20 matlab yalmip kkt 双层优化问题
  • ¥15 如何在3D高斯飞溅的渲染的场景中获得一个可控的旋转物体
  • ¥88 实在没有想法,需要个思路
  • ¥15 MATLAB报错输入参数太多
  • ¥15 python中合并修改日期相同的CSV文件并按照修改日期的名字命名文件
  • ¥15 有赏,i卡绘世画不出
  • ¥15 如何用stata画出文献中常见的安慰剂检验图
  • ¥15 c语言链表结构体数据插入