命名管道(FIFO)既可用于进程间通信，也可用于线程间通信;
FIFO是一种文件类型，一般文件I/O函数(close，read，write，unlink等)都适用于FIFO
一、管道创建：
#include
int mkfifo( const char* pathname, mode_t mode );
//成功返回0;否则返回-1
//mode为读写文件| 是否阻塞
二、管道默认读写——阻塞
a. 管道读取：如果没有线程进行写管道操作，读线程将一直阻塞，直到有线程往里面写为止
b. 管道写： 如果没有线程进行读操作，写线程将一直阻塞，直到有线程读数据为止
三、设置管道读写——不阻塞(O_NONBLOCK)
a、管道读：如果没有线程进行写管道操作，读线程将立即返回
b、 管道写：如果没有线程进行读操作，写线程将立即返回，返回错误码-1;errno： ENXIO
示例代码：获取vmstat的参数
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
/*定义FIFO路径*/
#define FIFO "myfifo"
#define FILE_PATH "conf.log"
int ncnt = 0;
int get_siso( char* str, int* si, int* so ){
assert( str != NULL );
char* sub_str;
FILE* fp = fopen( FILE_PATH, "ab+" );
sub_str = strtok( str, " " );
//ncnt = 0;
while( sub_str ){
if( sub_str != NULL && isdigit( sub_str[0] ) ){
fprintf( fp, " %s t", sub_str );
printf( "substr[%d] = %d n", ncnt, atoi(sub_str) );
ncnt++;
}
if( ncnt == 16 ){
ncnt = 0;
}
sub_str = strtok( NULL, " " );
//sleep(0.3);
}
fclose( fp );
printf( "nCnt is %dnnn", ncnt );
return 1;
}
int mf(){
char buf_r[1025];
int fd;
int nread;
printf("Preparing for reading bytes...n");
memset(buf_r,0,sizeof(buf_r));
//system( "vmstat 2 > myfifo" );
/*打开FIFO管道，不阻塞方式*/
//fd=open(FIFO,O_RDONLY|O_NONBLOCK,0);
fd=open(FIFO,O_RDONLY,0);
if(fd==-1)
{
perror("open");
exit(1);
}
while(1)
{
memset(buf_r,0,sizeof(buf_r));
if((nread=read(fd,buf_r,1024))==-1){
if(errno==EAGAIN)
printf("no data yetn");
}
sleep(2);
printf("nn%sn",buf_r);
get_siso( buf_r, NULL, NULL );
//sleep(1);
}
pause();
return 1;
}
void thr_get(){
pthread_detach( pthread_self() );
system( "vmstat 2 > myfifo" );
pthread_exit(0);
}
void thr_read(){
pthread_detach( pthread_self() );
pthread_t cthd;
int stat = pthread_create( &cthd, NULL, thr_get, NULL );
mf();
pthread_exit(0);
}
int main(int argc,char** argv)
{
int pid;
pthread_t cthd, dthd;
void* tret;
/*创建FIFO管道*/
if((mkfifo(FIFO,O_CREAT|O_EXCL)<0)&&(errno!=EEXIST)){
printf("cannot create fifoservern");
}
system( "chmod 777 myfifo" );
int tsts = pthread_create( &dthd, NULL, thr_read, NULL );
pthread_join( dthd, &tret );
printf( "tsts is %dn", tsts );
sleep( 60 );
unlink(FIFO);
}
