subprocess在读入协处理后挂起

我正在用pipe道编写一个协处理程序。 当孩子读取一些数据，处理它并输出它时，它工作正常。 但是，当我读取所有的数据并处理它，它只是悬而未决。 任何机构都有一些想法？ 谢谢。

这里是源代码：

#include <stdio.h> #include <unistd.h> #include <string.h> #include <stdlib.h> #include <errno.h> int main() { #define MAXSIZE 1024 char workload[MAXSIZE]; char result[MAXSIZE]; workload[strlen(workload)] = EOF; int workload_size = strlen(workload); int fd1[2], fd2[2]; int n; pid_t pid; if (pipe(fd1) < 0 || pipe(fd2) < 0) { fprintf(stderr, "pipe error: %s\n", strerror(errno)); exit(1); } if ((pid = fork()) < 0) { fprintf(stderr, "fork error: %s\n", strerror(errno)); exit(1); } else if (pid > 0) { close(fd1[0]); close(fd2[1]); while(fgets(workload, MAXSIZE, stdin) != NULL) { workload_size = strlen(workload); if (write(fd1[1], workload, workload_size) != workload_size) { fprintf(stderr, "write to pipe error: %s\n", strerror(errno)); exit(1); } if ((n = read(fd2[0], result, MAXSIZE)) < 0) { fprintf(stderr, "read from pipe error: %s\n", strerror(errno)); exit(1); } if (n == 0) { fprintf(stderr, "child closed the pipe\n"); exit(1); } result[n] = 0; if (puts(result) == EOF) { fprintf(stderr, "fputs error\n"); exit(1); } } } else { close(fd1[1]); close(fd2[0]); if (fd1[0] != STDIN_FILENO) { if (dup2(fd1[0] ,STDIN_FILENO) != STDIN_FILENO) { fprintf(stderr, "dup2 error to stdin.\n"); exit(1); } close(fd1[0]); } if (fd2[1] != STDOUT_FILENO) { if (dup2(fd2[1] ,STDOUT_FILENO) != STDOUT_FILENO) { fprintf(stderr, "dup2 error to stdout.\n"); exit(1); } close(fd2[1]); } if (execl("./a.out", "a.out", NULL) < 0) { fprintf(stderr, "execl error: %s\n", strerror(errno)); exit(1); } exit(0); } return 0; } 

这里是a.out的源代码，它适用于这个：

 #include <stdio.h> #include <string.h> int main() { #define MAXSIZE 1024 char x[MAXSIZE]; int n; while(scanf("%s", x) != EOF) { printf("len:%d %s", strlen(x), x); fflush(stdout); } return 0; } 

但是，当我写这样的代码时，似乎只是在等待：

• 如何限制文件select到一个单一的目录？
• 获取subprocessC ++的执行结果
• 在不修改内核的情况下拦截系统调用的最小开销方式
• 如何使用PHP将.NET源文件编译为可执行文件？
• C语言在指定的时间调用一个函数

 #include <stdio.h> #include <string.h> int main() { #define MAXSIZE 1024 char x[MAXSIZE]; int n; while(scanf("%s", x) != EOF); printf("Ok\n"); fflush(stdout); return 0; } 

 #include <stdio.h> #include <string.h> int main() { #define MAXSIZE 1024 char x[MAXSIZE]; int n; while(scanf("%1024s", x) != EOF) { printf("len:%d %s", strlen(x), x); fflush(stdout); } return 0; }