每次將每一行陣列傳遞給孩子

我正在從用戶那里讀取 arr 的大小。我創建 arr[row][col] 并用隨機整數填充它。然后我想將每一行從父行程發送到子行程，所以我創建一個新的 arr2 來每次將當前行存盤在其中。我將 arr2 讀取到子行程并計算行的總和。最后，我想將總和發送到父行程并列印出來。我在 for(i=0;i<row;i ) 中執行此操作。問題是子行程每次只取第一行。

#include <sys/types.h>
#include<stdio.h>
#include <unistd.h>
#include<time.h>
#include<stdlib.h>

int main(){

int gram, steiles;

printf("Dwse mou tis grammes tou pinaka\n");
scanf("%d", &gram);
printf("Dwse mou tis steiles tou pinaka\n");
scanf("%d", &steiles);

int arr[gram][steiles];
int arr2[gram];

srand(time(NULL));

for (int i = 0; i < gram; i  ) {
  for (int j = 0; j < steiles; j  ) {
    arr[i][j] = rand() % 20   1;
  }
}

for (int i = 0; i < gram; i  ) {
  for (int j = 0; j < steiles; j  ) {
    printf("%d", arr[i][j]);
    printf("\t");
  }
  printf("\n");
}
pid_t pid;
int fd[2], fd1[2], sum=0;

if (pipe(fd) == -1) {
  return 2;
}
if (pipe(fd1) == -1) {
  return 3;
}

    for (int i = 0; i < gram; i  ) {
      pid = fork();
    
      if (pid<0) {
        return 1;
      }
    
      if (pid>0){   
        for (int j = 0; j < steiles; j  ) {
          arr2[j]=arr[i][j];
        }
    
        close(fd[0]);
        write(fd[1], arr2, sizeof(int)*steiles);
        close(fd[1]);
    
        close(fd1[1]);
        read(fd1[0], &sum, sizeof(int));
        close(fd1[0]);
        printf("the sum of the row is: %d", sum);
    
    
      }else{ 
        wait(NULL);
        close(fd[1]);
        read(fd[0], arr2, sizeof(int)* steiles);
        close(fd[0]);
        for (int k = 0; k < steiles; k  ) {
          // printf("%d\t", arr2[k]);
          sum =arr2[k];
        }
        close(fd1[0]);
        write(fd1[1], &sum, sizeof(int));
        close(fd1[1]);
      }
}
}

uj5u.com熱心網友回復：

我在上面的評論中概述了許多問題，包括：

• 您不會錯誤檢查您的 I/O 呼叫，但應該這樣做。
• 父行程關閉第一個子行程的管道；第二個和以后的孩子沒有機會，可憐的東西。他們被剝奪了與父母的所有交流，你知道孩子從與父母交談中受益多少。
• 在回圈內部而不是外部創建管道。請注意，檢查 I/O 呼叫的錯誤會告訴您這個問題。
• 不要忘記用換行符結束訊息。
• 此外，請確保您的子行程在完成作業后退出。就目前而言，第一個孩子讀取其資料，然后回傳回圈以運行新孩子（以及運行新孩子的父母）。

下面是一些仍然跳過 I/O 錯誤檢查但作業正常的代碼：

#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <unistd.h>

static void dump_vector(const char *tag, size_t size, const int *data);

int main(void)
{
    int gram, steiles;

    printf("Dwse mou tis grammes tou pinaka\n");
    scanf("%d", &gram);
    printf("Dwse mou tis steiles tou pinaka\n");
    scanf("%d", &steiles);

    int arr[gram][steiles];
    int arr2[gram];

    srand(time(NULL));

    for (int i = 0; i < gram; i  )
    {
        for (int j = 0; j < steiles; j  )
        {
            arr[i][j] = rand() % 20   1;
        }
    }

    for (int i = 0; i < gram; i  )
    {
        for (int j = 0; j < steiles; j  )
        {
            printf("%d", arr[i][j]);
            printf("\t");
        }
        printf("\n");
    }

    for (int i = 0; i < gram; i  )
    {
        pid_t pid;
        int fd1[2], fd2[2];

        if (pipe(fd1) == -1)
        {
            return 2;
        }
        if (pipe(fd2) == -1)
        {
            return 3;
        }
        pid = fork();

        if (pid < 0)
        {
            return 1;
        }

        if (pid > 0)
        {
            for (int j = 0; j < steiles; j  )
            {
                arr2[j] = arr[i][j];
            }

            dump_vector("arr2 - parent", steiles, arr2);

            close(fd1[0]);
            write(fd1[1], arr2, sizeof(int) * steiles);
            close(fd1[1]);

            int sum = 0;
            close(fd2[1]);
            read(fd2[0], &sum, sizeof(int));
            close(fd2[0]);
            printf("the sum of the row is: %d\n", sum);
        }
        else
        {
            close(fd1[1]);
            read(fd1[0], arr2, sizeof(int) * steiles);
            close(fd1[0]);
            dump_vector("arr2 - child", steiles, arr2);
            int sum = 0;
            for (int k = 0; k < steiles; k  )
            {
                // printf("%d\t", arr2[k]);
                sum  = arr2[k];
            }
            printf("Child %d (%d): sum = %d\n", i, getpid(), sum);
            close(fd2[0]);
            write(fd2[1], &sum, sizeof(int));
            close(fd2[1]);
            exit(0);
        }
    }
    return 0;
}

static void dump_vector(const char *tag, size_t size, const int *data)
{
    int length = printf("%s (%zu):", tag, size);
    for (size_t i = 0; i < size; i  )
    {
        length  = printf(" -", data[i]);
        if (length > 60)
        {
            length = 0;
            putchar('\n');
        }
    }
    if (length > 0)
        putchar('\n');
}

我發現類似dump_vector()的功能非常有用；我為許多資料結構撰寫它們。有時我也接受一個FILE *fp論點，但標簽是至關重要的。對于陣列，大小和資料是必要的；對于單個結構，當然只是結構。

示例輸出

Dwse mou tis grammes tou pinaka
4
Dwse mou tis steiles tou pinaka
10
12  12  4   3   8   12  6   4   2   10  
10  13  14  13  13  1   7   12  4   8   
7   12  19  12  14  18  20  13  8   8   
5   14  7   11  19  16  4   12  14  18  
arr2 - parent (10): 12 12  4  3  8 12  6  4  2 10
arr2 - child (10): 12 12  4  3  8 12  6  4  2 10
Child 0 (15771): sum = 73
the sum of the row is: 73
arr2 - parent (10): 10 13 14 13 13  1  7 12  4  8
arr2 - child (10): 10 13 14 13 13  1  7 12  4  8
Child 1 (15772): sum = 95
the sum of the row is: 95
arr2 - parent (10):  7 12 19 12 14 18 20 13  8  8
arr2 - child (10):  7 12 19 12 14 18 20 13  8  8
Child 2 (15773): sum = 131
the sum of the row is: 131
arr2 - parent (10):  5 14  7 11 19 16  4 12 14 18
arr2 - child (10):  5 14  7 11 19 16  4 12 14 18
Child 3 (15774): sum = 120
the sum of the row is: 120

標籤：C Unix

上一篇：NGINX容器作為其他容器的代理

下一篇：linux下如何監控行程