苏州网站建设专业的公司,承德网站设计公司,开源wiki做网站,南京高端网站建设哪家好管道管道是unix ipc的最古老形式#xff0c;是一种在内存中的特殊文件#xff0c;只能在具有公共祖先的进程之间使用(即父子进程#xff0c;兄弟进程)。管道由pipe函数创建#include int pipe(int fd[2])fd[1]写#xff0c;fd[0]读。单个进程的管道几乎没有任何用处#xf…管道管道是unix ipc的最古老形式是一种在内存中的特殊文件只能在具有公共祖先的进程之间使用(即父子进程兄弟进程)。管道由pipe函数创建#include int pipe(int fd[2])fd[1]写fd[0]读。单个进程的管道几乎没有任何用处通常调用pipe的进程接着调用fork这样就创建了父子进程间的管道。#include #include#include#includeintmain(){int fd[2];char buf[80];pid_t pid;pipe(fd);pidfork();if(pid0){//父进程printf(Father thread);char s[]Hello;write(fd[1],s,sizeof(s));close(fd[0]);close(fd[1]);}else if(pid0){printf(Child Thread);read(fd[0],buf,sizeof(buf));printf(%s,buf);close(fd[0]);close(fd[1]);}waitpid(pid,NULL,0);//等待子进程结束return 0;}输出结果Father threadChild ThreadHello当管道的一端关闭时当读一个写端关闭的管道时则认为已经读到了数据的末尾读函数返回的读出字节数为0当写一个读端关闭的管道时向管道中写入数据的进程将收到内核传来的SIFPIPE信号应用程序可以处理该信号也可以忽略(默认动作则 是应用程序终止)。从管道中读取数据当管道的写端存在时如果请求的字节数目大于PIPE_BUF则返回管道中现有的数据字节数如果请求的字节数目不大于PIPE_BUF则返回管道中现有数据字节数(此时管道中数据量小于请求的数据量)或者返回请求的字节数(此时管道中数据量不小于请求的数据量)。注PIPE_BUF在include/linux/limits.h中定义。向管道中写入数据向管道中写入数据时linux将不保证写入的原子性管道缓冲区一有空闲区域写进程就会试图向管道写入数据。如果读进程不读走管道缓冲区中的数据那么写操作将一直阻塞。管道因为没有名字所以只能用于具有亲缘关系的进程而有名管道(FIFO)则克服了这个限制。FIFO创建函数如下#include #includeint mkfifo(const char *pathname, mode_t mode);第一个参数是一个普通的路径名即为FIFO的名字。第二个参数设置权限跟创建普通文件一样。FIFO的读写也像普通文件一样不过需要读写端都打开具体规则如下当打开(open)时若没有设置O_NONBLOCK只读open要阻塞到其它进程为写而打开FIFO。类似地只写open要阻塞到其它进程为读而打开FIFO。如果设置了O_NONBLOCK则只读open立即返回若没有其它进程为写而打开FIFO则返回-1。用FIFO模拟生产者消费者问题fifo2.cpp:#include#include#include#include#include#include#include#include#include#include#define FIFO /tmp/myfifo#define BUF_SIZE PIPE_BUF#define SEND_MAX (1024*1024*10)using namespacestd;intmain(){intpid,fifo_fd;intsend_num;char *buf[BUF_SIZE1];if(-1 access(FIFO,F_OK)){int res mkfifo(FIFO,0777);if(res ! 0){fprintf(stderr,cant create fifo in %s,FIFO);exit(EXIT_FAILURE);}}fifo_fdopen(FIFO,O_WRONLY);printf(process %d open fifo %d,getpid(),fifo_fd);if(fifo_fd -1)exit(EXIT_FAILURE);intres;while(send_num{reswrite(fifo_fd,buf,BUF_SIZE);if(res -1){coutexit(EXIT_FAILURE);}send_numres;}return 0;}fifo3.cpp#include#include#include#include#include#include#include#include#include#include#define FIFO /tmp/myfifo#define BUF_SIZE PIPE_BUF#define SEND_MAX (1024*1024*10)using namespacestd;intmain(){intfifo_fd;intres;char buffer[BUF_SIZE1];int read_num 0;fifo_fdopen(FIFO,O_RDONLY);printf(process %d open FIFO %d,getpid(),fifo_fd);if(fifo_fd -1)exit(EXIT_FAILURE);do{resread(fifo_fd,buffer,BUF_SIZE);read_numres;}while(res0);close(fifo_fd);return 0;}结果如下可见读进程运行0.013s就读取了10m的数据FIFO的效率还是很高的。
