码迷,mamicode.com
首页 > 系统相关 > 详细

进程间通信:命名管道

时间:2017-04-21 22:47:46      阅读:219      评论:0      收藏:0      [点我收藏+]

标签:返回   filename   nbsp   匿名   sem   main   mode   pip   types.h   

一、命名管道(FIFO)

匿名管道应用的一个限制就是只能在具有共同祖先(具有亲缘关系)的进程间通信。
如果我们想在不相关的进程之间交换数据,可以使用FIFO文件来做这项工作,它经常被称为命名管道。

命名管道可以从命令行上创建,命令行方法是使用下面这个命令:
$ mkfifo filename
命名管道也可以从程序里创建,相关函数有:
int mkfifo(const char *filename,mode_t mode);

 

二、命名管道和匿名管道

匿名管道由pipe函数创建并打开。
命名管道由mkfifo函数创建,打开用open。
FIFO(命名管道)与pipe(匿名管道)之间唯一的区别在它们创建与打开的方式不同,这些工作完成之后,它们具有相同的语义。

The  only difference between pipes and FIFOs is the manner in which they are created and opened.  Once these tasks have been accomplished, I/O on pipes and FIFOs has exactly the same semantics.

 

三、命名管道的打开规则

如果当前打开操作是为读而打开FIFO时
O_NONBLOCK disable:阻塞直到有相应进程为写而打开该FIFO
O_NONBLOCK enable:立刻返回成功
如果当前打开操作是为写而打开FIFO时
O_NONBLOCK disable:阻塞直到有相应进程为读而打开该FIFO
O_NONBLOCK enable:立刻返回失败,错误码为ENXIO

 

#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <string.h>
#include <sys/syscall.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>


#ifndef T_DESC
#define T_DESC(x, y)   (y)
#endif

#if T_DESC("TU1", 1)

int tu1_proc(void)
{
    int fifo_fd;
    int ret;
    char buffer[128];
    
    mkfifo("my_fifo", 0644);
    fifo_fd = open("my_fifo", O_WRONLY);
    printf("fifo_fd: %d\n", fifo_fd);

    for( ; ; )
    {
        printf("\n input write buffer: ");
        fgets(buffer, sizeof(buffer), stdin);

        if(strncmp(buffer, "exit", 4) == 0) break;

        ret = write(fifo_fd, buffer, strlen(buffer) + 1);
        printf("write: %d\n", ret);
    }

    close(fifo_fd);
    unlink("my_fifo"); 
    
    return 0;
}

#endif

#if T_DESC("TU2", 1)

int tu2_proc(void)
{
    int fifo_fd;
    int ret;
    char buffer[128];
    
    //mkfifo("my_fifo", 0644);
    fifo_fd = open("my_fifo", O_RDONLY);
    printf("fifo_fd: %d\n", fifo_fd);

    for( ; ; )
    {
        ret = read(fifo_fd, buffer, 128);
        if(ret > 0) {
            printf("read: %s\n", buffer);
        }
    }

    return 0;
}

#endif

#if T_DESC("global", 1)

void usage()
{
    printf("\n Usage: <cmd> <tu> <p1> <...>");
    printf("\n   1 -- create thread 1");
    printf("\n   2 -- create thread 2");
    printf("\n");
}

int main(int argc, char **argv)
{
    int ret;
    
    if(argc < 2) {
        usage();
        return 0;
    }

    int tu = atoi(argv[1]);
    if (tu == 1) ret = tu1_proc();
    if (tu == 2) ret = tu2_proc();
    
    return ret;
}
#endif

 

进程间通信:命名管道

标签:返回   filename   nbsp   匿名   sem   main   mode   pip   types.h   

原文地址:http://www.cnblogs.com/soul-stone/p/6746233.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!