多方读写管道的同步问题

本文主要是介绍多方读写管道的同步问题，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

多方读写管道的同步问题

管道本身给读写双方提供了同步处理，可以简单处理实现“没写完不能读”，“没有读空缓冲区不能写”。
但如果一个管道的读、写方有多个，那么这多个进程间的读写问题仍需要编程人员根据读、写各方间的关系进行同步处理

实例：
父进程生成子进程P1、P2，两个子进程分别向管道写入各自的字符串，而父进程负责读出它们。

在这里插入图片描述

#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/wait.h>
int main(void)
{int r,i,p1,p2,fd[2];char buf[10],s[50];pipe(fd);          				//创建管道while((p1=fork())==-1);        	//创建子程序失败时，循环if(p1==0){    //lockf(fd[1],1,0);        //互斥锁定区域sprintf(buf, "AAAAAAAAAA\n");printf("child process p1 WRITE!\n");for(i=1;i<=10;i++)        {    	write(fd[1],buf,10);    //把buf中的字符写入管道sleep(1);        }//lockf(fd[1],0,0);			//解锁exit(0);                } else{    while((p2=fork())==-1);		//创建子程序失败时，循环if(p2==0){    //lockf(fd[1],1,0);		//互斥锁定区域sprintf(buf, "BBBBBBBBBB\n");printf("child process p2 WRITE!\n");for(i=1;i<=10;i++)        {    	write(fd[1],buf,10);    //把buf中的字符写入管道sleep(1);    }//lockf(fd[1],0,0);			//解锁exit(0);                } //father read        printf("father read：\n");for(i=1;i<=20;i++)        {if((r=read(fd[0],s,10))==-1)printf("can’t read pipe\n");elseprintf("%s",s);        }printf("father read end.\n");wait(0);wait(0);exit(0);}  
}///lockf:
#inlude<unistd.h>
int lockf(int fd, int cmd, off_t len)
-fd 是打开文件的文件描述符。为通过此函数调用建立锁定，文件描述符必须使用只写权限（O_WRONLY）或读写权限（O_RDWR）打开。如果调用进程是具有PRIV_LOCKRDONLY 权限的组的成员，它也可以使用lockf()来锁定使用只读权限（O_RDONLY）打开的文件
-cmd 是指定要采取的操作的控制值，允许的值在中定义如下所示：# define F_ULOCK 0 		//解锁# define F_LOCK 1 		//互斥锁定区域# define F_TLOCK 2 		//测试互斥锁定区域# define F_TEST 3 		//测试区域
-len是要锁定或解锁的连续字节数。要锁定的资源从文件中当前偏移量开始，对于正 len 将向前扩展，对于负len 则向后扩展（直到但不包括当前偏移量的前面的字节数）。如果 len 为零，则锁定从当前偏移量到文件结尾的区域（即从当前偏移量到现有或任何将来的文件结束标志）。要锁定一个区域，不需要将该区域分配到文件中，因为这样的锁定可以在文件结束标志之后存在。
-返回值此函数调用成功后，将返回值 0，否则返回−1，并且设置 errno 以表示该错误。 由于当文件的某部分被其他进程锁定后，变量 errno 将会设置为[EAGAIN]而不是[EACCES]，因此可移植应用程序应对这两个值进行预计和测试。