C 并发程序(连载)

Question

我正在尝试找到一种方法来使该算法同时运行。到目前为止，它只有 1 个 for 循环来读取每个文件，然后为每个文件创建一个进程。

我相信这个算法是按顺序运行的，这不是我想要的......我考虑创建一个外部 for 循环，在其中放置 wait(null) 和 read 命令。但当我尝试时它不起作用，没有产生输出。目前我在父进程中有 wait(null) 命令。

有什么建议吗？

代码:

int main(int argc, char *argv[])
{
   // ATTRIBUTES //
   int freq[argc-1], ipc[argc][2], nbytes, i;// freq of words, pipes, counters
   ssize_t errorfi;
   char  readbuffer[9999];
   char** k = malloc(50);
   char** op = malloc(50);


   if(argc == ONE) { // there are no files given, throw error and close
     fprintf(stderr, "There are no files found from %s\n", argv[0]);
     exit(0);
   }

  for(i = 1; i < argc; i++) // creates pipes for ipc
     pipe(ipc[i]);

  pid_t pids[argc-1]; // array of pids
  for(i = 1; i < argc; i++) { // reads input after position 0(a.out)

      pid_t pid = fork(); // creates process
      pids[i-1] = pid;
      if( pid < 0 ) {       // bad fork process: error
         perror("bad fork");
         exit(0);
      }
      else if(pid > 0) {   //parent process

         close(ipc[i][1]);
         wait(NULL);
         nbytes = read(ipc[i][0], readbuffer, sizeof(readbuffer));

        if(nbytes > 0)
          printf("%s\n", readbuffer);
      }
      else if(pid == 0) {  // child process

           close(ipc[i][0]);

           k = inputReader(argv[i]); // finds filename,w1,w2,w3,uniqueWords

           char info[50] = "";

           strcat(info, k[0]);
           strcat(info, " ");
           strcat(info, k[1]);
           strcat(info, " ");
           strcat(info, k[2]);
           strcat(info, " ");
           strcat(info, k[3]);
           strcat(info, " ");
           strcat(info, k[4]);

           int uniqueWordint = atoi(k[4]);
           freq[i-1] = uniqueWordint; // freq of all uniqueWords

           errorfi = write(ipc[i][1], info, strlen(info)+1); // writes info to pipe i

           if (errorfi < 0 ) {

              fprintf(stderr, "error found when writing in pipe errofi: %d\n", errorfi);
              exit(0);
           }

          exit(0); // close process
      } // closes child process
   } // closes for-loop for each process

   for(j = 0; j < argc-1; j++) {
        wait(2); // if i put read command here it won't work
   }
   return(0); // close main 
 }  

Answer 1

这确实是一个顺序执行。父进程进入循环， fork 子进程，然后在该子进程完成之前不会继续下一个循环。

您可以做的是创建一个大小为 argc 的 pid_t 数组，以存储每个 fork() 的返回值。还在“每个进程的 for 循环”之后创建一个新循环，其中父进程将使用 wait(2) 等待其所有子进程。或waitpid(2) ，取决于您是否需要按特定顺序处理每个子级的结果，并继续处理它们(读取或任何需要的内容。