我之前发布了一个关于在 C 中使用 fork() 和管道的问题 。我稍微改变了设计,让它读取一个常规的 txt 文件并对文件中的单词进行排序。到目前为止,这是我想出的:
for (i = 0; i < numberOfProcesses; ++i) {
// Create the pipe
if (pipe(fd[i]) < 0) {
perror("pipe error");
exit(1);
}
// fork the child
pids[i] = fork();
if (pids[i] < 0) {
perror("fork error");
} else if (pids[i] > 0) {
// Close reading end in parent
close(fd[i][0]);
} else {
// Close writing end in the child
close(fd[i][1]);
int k = 0;
char word[30];
// Read the word from the pipe
read(fd[i][0], word, sizeof(word));
printf("[%s]", word); <---- **This is for debugging purpose**
// TODO: Sort the lists
}
}
// Open the file, and feed the words to the processes
file_to_read = fopen(fileName, "rd");
char read_word[30];
child = 0;
while( !feof(file_to_read) ){
// Read each word and send it to the child
fscanf(file_to_read," %s",read_word);
write(fd[child][1], read_word, strlen(read_word));
++child;
if(child >= numberOfProcesses){
child = 0;
}
}
wherenumberOfProcesses
是一个命令行参数。所以它的作用是读取文件中的每个单词并将其发送到一个进程。然而,这不起作用。当我在子进程中打印单词时,它没有给我正确的输出。我是否正确地从管道中写入/读取单词?