我有以下代码.它由父进程和两个子进程(生产者和消费者)组成.生产者接受用户输入并将其传递给消费者,消费者总结了已经发生的元音总数.父进程只是监听两个子进程,如果它们由于某种原因而停止,则重新启动它们.当用户输入'p'时,生产者进程退出,当接收到包含'y'的字符串时,消费者进程停止.
我遇到的问题是_exit()生产者进程中的函数调用不会导致进程终止._exit()消费者流程中的函数调用按预期工作.为什么消费者进程在生产者函数没有正确终止时?
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>
int main(){
pid_t c_p, c_c;
int p[2];
pipe(p);
c_p = fork();
if(c_p > 0) c_c = fork();
for(;;){
// Producer Process
if(c_p == 0){
char c[20];
printf("%s", "Enter a string: \n");
fgets(c, 20, stdin);
if(c[0] == 'p' && strlen(c) == 2) _exit(1);
close(p[0]);
write(p[1], c, (strlen(c) + 1));
}
// Consumer Process
else if(c_c == 0){
int j;
static int a = 0, e = 0, i = 0, o = 0, u = 0;
char buffer[20];
close(p[1]);
read(p[0], buffer, sizeof(buffer));
for(j = 0; j < strlen(buffer); j++){
if (buffer[j] == 'a' || buffer[j] == 'A') a++;
else if(buffer[j] == 'e' || buffer[j] == 'E') e++;
else if(buffer[j] == 'i' || buffer[j] == 'I') i++;
else if(buffer[j] == 'o' || buffer[j] == 'O') o++;
else if(buffer[j] == 'u' || buffer[j] == 'U') u++;
else if(buffer[j] == 'y' || buffer[j] == 'Y') _exit(1);
}
printf("Sum of Vowels... \tA: %d \tE: %d \tI: %d \tO: %d \tU: %d\n", a, e, i, o, u);
}
// Main Process
else{
int status;
pid_t result = waitpid(c_c, &status, WNOHANG);
if(result > 0){
c_c = fork();
}
/*result = waitpid(c_p, &status, WNOHANG);
if(result > 0){
c_p = fork();
}*/
}
}
return 0;
}
Run Code Online (Sandbox Code Playgroud)
小智 5
之后程序中有四个进程
c_p = fork();
c_c = fork();
您可以将其更改为:
c_p = fork();
if (c_p > 0)
{
c_c = fork();
// Do something.
} else if (c_p == 0)
{
// Do something.
}
Run Code Online (Sandbox Code Playgroud)