标签：include int strlen write 管道 fd linux 多线程 buf

参考  (129条消息) linux c 使用fifo管道进行多线程间通信_土豆西瓜大芝麻的博客-CSDN博客_多线程fifo

稍作修改

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

//编译    gcc -o t03_testfifo t03_testfifo.c -lpthread
 
void *thread_fun_write(void *p)
{
    char *buf = "12345\n"; //加上\0一共7个字符
    int fd;
    fd = open("./myfifo",O_WRONLY);
    if(fd == -1)
    {
        printf("write fifo open fail....\n");
        exit(-1);
        return NULL;
    }
    while(1)
    {
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        write( fd, buf, strlen(buf)+1 );
        printf("write ok\n");
        sleep(2);
    }
    close(fd);
    return NULL;
}
void *thread_fun_read(void *p)
{
 
    int fd;
 
    fd = open("./myfifo", O_RDONLY );
    if(fd == -1)
    {
        printf("read fifo open fail...\n");            
        exit(-1);
        return NULL;
    }
    char buf[1024] = {0};
    int num;//保存读取数据的大小
    while(1)
    {
        memset(buf,0,1024);
        num = read( fd, buf, 1024 );
        printf("read ok num:%d\n",num);
        for(int i=0;i<num;i++){
            printf("%c",buf[i]);
        }
        puts(buf);
    }
    close(fd);
    return NULL;
}
int main()
{
    printf("test fifo v1.0.3 \n");
    
    //创建有名管道，如果管道存在则直接使用
    int n = mkfifo("./myfifo",0664);
    if( n < 0 && errno!=EEXIST)
    {
        perror("mkfifo");
        return -1;
    }
    //创建线程
    pthread_t writeId,readId;
    pthread_create( &writeId, NULL, thread_fun_write, NULL );
    pthread_create( &readId, NULL, thread_fun_read, NULL);
 
    pthread_join(writeId,NULL);
    pthread_join(readId,NULL);
    while(1);
    return 0;
}

//

标签：include,int,strlen,write,管道,fd,linux,多线程,buf
来源： https://www.cnblogs.com/RYSBlog/p/16580314.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。