//通过epoll监控管道的读端
#include
#include
#include
#include
#include
#include
#include
#include
int main()
{
//管道
int fd[2];
pipe(fd);
//创建子进程
pid_t pid = fork();
if(pid == 0){
//子进程
//子进程写dd
close(fd[0]);//关闭读端
char buf[12]={0};
buf[10]='\n';
char ch = 'A';
while(1){
memset(buf,ch,10);//将字符串设置为AAAAAAAAAA
ch++;
write(fd[1],buf,strlen(buf));
sleep(3);
break;
}
}else{
//父进程读
close(fd[1]);//关闭写端
//--创建根节点
int epfd = epoll_create(1);
//--加入监听节点
struct epoll_event ev,epv;
ev.data.fd = fd[0];
//ev.events = EPOLLIN|EPOLLET;//添加边缘触发模式
ev.events = EPOLLIN;//水平触发
epoll_ctl(epfd,EPOLL_CTL_ADD,fd[0],&ev);//上树
//int flags = fcntl(fd[0],F_GETFL);
//flags |= O_NONBLOCK;
//fcntl(fd[0],F_SETFL,flags);//设置文件描述符为非阻塞
while(1){
//--循环等待事件产生
int ready = epoll_wait(epfd,&epv,1,-1);
printf("ready--------===%d\n",ready);
//--读内容,输出到屏幕
char buf[6];
memset(buf,0x00,sizeof(buf));
int ret = read(epv.data.fd,buf,sizeof(buf));
//write(STDOUT_FILENO,buf,ret);
printf("read:%s\n",buf);
}
}
return 0;
}
这里面用epoll 模式,在管道间通信。子进程退出循环了。但是父进程还是能够接受到事件。