编程语言
首页 > 编程语言> > 使用读写管道作为事件通知的C++实现

使用读写管道作为事件通知的C++实现

作者:互联网

在用C++编写程序时,经常会在某个事件发生后开始处理相应的任务,这种方式在Qt中可以利用到信号与槽来很方便的实现,但在服务器编程时,则需要自己来实现事件通知模块。

在此,提供利用用读写管道来实现事件通知,从而可以实现对异步事件的响应处理。

  1. 创建读写管道,且添加至epoll监听事件中

boo createPipe()
{
     //创建管道服务器句柄
    sock_fd = -1;

    int pipe_fds[2] = {-1, -1};
    if (pipe(pipe_fds) != 0)
    {
        return false;
    }

    sock_fd         = pipe_fds[0];
    pipe_send_fd     = pipe_fds[1];

    //非阻塞设置
    int val = fcntl(sock_fd, F_GETFL, 0);
    if (fcntl(sock_fd, F_SETFL, val | O_NONBLOCK) == -1)
    {
          return false
     }
    // 添加至epoll监听的事件中,等待epoll_wait返回
}

 

  2. 向pipe_send_fd写入数据

if(write(pipe_send_fd, "", 1) != 1) //一般是向某个队列发送数据之后,通过这种方式通知另一个线程来处理队列中的数据

 

  3. epoll_wait返回,再调用相应的接收数据事件处理函数

int OnRecv()
{
    char buf[1];
    if (read(sock_fd, buf, 1) != 1)
    {
        return 0;
    }

    //获取任务,开始处理任务
    MsgTask asyn_task;
    if (!getMessage(asyn_task))
    {
        return 0;
    }
    return 1;
}

 

标签:return,epoll,读写,sock,fds,C++,pipe,管道,fd
来源: https://www.cnblogs.com/share-ideas/p/10849319.html