c++ - 使用 pthread 打印二维数组

Question

所以我有一个作业说我已经创建了一个二维数组 [5][12]，其随机值介于 1-99 之间。然后使用 pthreads，我必须对数组中的每个元素加 1 或减 1，然后打印结果并将进程分成 2、3 或 4 个线程。线程数取决于用户在命令行中输入的内容。我有编译和运行的代码。但是，我想要的输出仅在输入数字 3 时打印。你们能告诉我我的代码哪里出错了吗？我一开始就无法理解 pthread。

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <ctype.h>
#include <pthread.h>
#include <iostream>

using namespace std;
int list[5][12];
int rows = 5;
int cols = 12;
int threadc;

void *threadf(void *arg)
{
    int x = (int) arg;
    for(int i = (x*60)/threadc; i < ((x+1) * 60)/threadc; i++)
    {
        for(int j = 0; j < 12; j++)
        {
            if (list[i][j] % 2 == 0)
                list[i][j] += 1;
            else
                list[i][j] -= 1;
        }
    }
}

void cArray()
{
    srand(time(NULL));
    for(int i = 0; i < 5; i++)
    {
        for(int j = 0; j < 12; j++)
        {
            list[i][j] = rand() % 99 + 1;
        }
    }

}

void pArray(int list[][12], int rows, int cols)
{
    cout << "\n";
    for(int i = 0; i < rows; i++)
    {
        for(int j = 0; j < cols; j++)
        {
            cout << list[i][j] << " ";
        }
        cout << "\n";
    }
 }

int main(int argc, char *argv[])
{
    if(argc != 2) exit(0);
    threadc = atoi(argv[1]);
    assert(threadc >= 2 && threadc <=4);
    pthread_t *thread;
    thread = new pthread_t [threadc];
    if(thread == NULL)
        exit(0);
    cArray();
    cout << "2-d Array: ";
    pArray(list, rows, cols);
    int t;
    for(int i = 0; i < threadc; i++)
    {
        t = pthread_create(&thread[i], NULL, threadf, (void *)i);
        if (t != 0)
            return 1;
    }
    for(int i = 0; i < threadc; i++)
    {
        t = pthread_join(thread[i], NULL);
        if(t != 0)
            return 1;
    }  
    cout << "Modified 2-d Array: ";
    pArray(list, rows, cols);
    return 0;
}

Answer 1

让我们看一下 threadf 中 x = 0 和 threadc = 4 的外部 for 循环

    for(int i = (0*60)/4; i < ((0+1) * 60)/4; i++)
    for(int i = 0; i < (1 * 60)/4; i++)
    for(int i = 0; i < 60/4; i++)
    for(int i = 0; i < 15; i++)

i 的范围从 0 到 14。i 的使用方式如下:list[i][j]，因此请考虑写入 list[14 的位置][11] 会去。超出 int list[5][12]; 定义的边界就会发生坏的 smurf。未定义的行为，所以从技术上讲没有人知道会发生什么。不过，我们可以做出一些很好的猜测。

int list[5][12];
int rows = 5; // probably overwritten by write to list[6][0]
int cols = 12; // probably overwritten by write to list[6][1]
int threadc; // probably overwritten by write to list[6][3]

所以 row 和 column 都在移动，但没人在意。代码从不使用它们。但是 threadc...到处都在使用它。事实上，它被用在循环退出条件中。这里可能会发生更多的坏事。它还确定要创建和加入的线程数。某些线程可能不会创建。该程序可能会尝试加入比现有更多的线程。

无论如何，未定义的行为。我想我们都应该为编译器没有生成命令进行战术核打击的代码而感到高兴。由于这是一个家庭作业问题，我不打算解释数学 OP 要求使他们的 for 循环正确地跨多个线程分配工作，但会建议他们考虑将数组视为大小为 5*12 的一维数组，并在单个 for 循环中自行执行 1D->2D 索引。

其他说明:

main 中的 i 和 x 中使用 uintptr_t 而不是 int 线程。 uintptr_t 保证转换为 void *

为循环计数器和数组索引器使用无符号变量，如 size_t。它们与 uintptr_t 配合得很好，您几乎永远不需要负数数组索引。

使用 std::vector 而不是指针，并为线程列表使用 new。如果您必须使用 new 和指针，请记住在用完后删除列表。

看看您是否可以使用 std::thread 而不是 pthread。

向threadf 添加一个return。