我正在写解析输入从STDIN成词一个C程序,生成许多由numsorts变量指定的排序过程,管,可在一个循环方式向每个排序过程的话,并发送各种输出到stdout。
我的程序工作需要的和干净地退出。如果指定的排序过程的数量为1,但如果分类处理的数量大于1的排序子进程不会死,我的程序卡住等着他们。 这样做的奇怪的一部分,对我来说,如果我打开一个单独的终端窗口,杀死所有的孩子,除了1,最后一个孩子死于立即自身和程序干净地退出。
这是我的解析器(管文件描述符被存储在2维阵列)的代码:
void RRParser(int numsorts, int **outPipe){ //Round Robin parser
int i;
char word[MAX_WORD_LEN];
//Close read end of pipes
for(i = 0; i < numsorts; i++){
closePipe(outPipe[i][0]);
}
//fdopen() all output pipes
FILE *outputs[numsorts];
for(i=0; i < numsorts; i++){
outputs[i] = fdopen(outPipe[i][1], "w");
if(outputs[i] == NULL)
printf("Error: could not create output stream.\n");
}
//Distribute words to them
i = 0;
while(scanf("%[^,]%*c,", word) != EOF){
strtoupper(word);
fputs(word, outputs[i % numsorts]); //round robin
fputs("\n", outputs[i % numsorts]); //sort needs newline
i++;
}
//Flush the streams:
for(i=0; i < numsorts; i++){
if(fclose(outputs[i]) == EOF)
printf("Error closing stream.\n");
}
}
下面是生成分类处理(PukeAndExit()会打印出错误信息并退出)的代码:
int *spawnSorts(int numsorts, int **inPipe){
//returns an array containing all the PIDs of the child processes
//Spawn all the sort processes
pid_t pid;
int i;
int *processArray = (int *)malloc(sizeof(int) * numsorts);
for(i = 0; i < numsorts; i++){
switch(pid = fork()){
case -1: //oops case
PukeAndExit("Forking error\n");
case 0: //child case
//Bind stdin to read end of pipe
closePipe(inPipe[i][1]); //close write end of input pipe
if(inPipe[i][0] != STDIN_FILENO){ //Defensive check
if(dup2(inPipe[i][0], STDIN_FILENO) == -1)
PukeAndExit("dup2 0");
closePipe(inPipe[i][0]); //Close duplicate pipe
}
execlp("sort", "sort", (char *)NULL);
break;
default: //parent case
processArray[i] = pid;
}
}
return processArray;
}
在main()结束,下面是等待分类处理死的代码:
for(i=0; i<numsorts; i++){ //wait for child processes to die.
wait(NULL);
}