多输入select

IO模型

首先介绍下IO模型,摘录《嵌入式Linux应用程序开发标准教程》

I/O 处理的模型有 5 种。

阻塞 I/O 模型：在这种模型下，若所调用的 I/O 函数没有完成相关的功能，则会使进程挂起，直到相关数据到达才会返回。对管道设备、终端设备和网络设备进行读写时经常会出现这种情况
非阻塞模型：在这种模型下，当请求的 I/O 操作不能完成时，则不让进程睡眠，而且立即返回。非阻塞 I/O 使用户可以调用不会阻塞的 I/O 操作，如 open()、 write()和 read()。如果该操作不能完成，则会立即返回出错（例如：打不开文件）或者返回 0（例如：在缓冲区中没有数据可以读取或者没有空间可以写入数据）。
I/O 多路转接模型：在这种模型下，如果请求的 I/O 操作阻塞，且它不是真正阻塞 I/O，而是让其中的一个函数等待，在这期间， I/O 还能进行其他操作。 select()和 poll 函数()就是属于这种模型。
信号驱动 I/O 模型：在这种模型下，通过安装一个信号处理程序，系统可以自动捕获特定信号的到来，从而启动 I/O。这是由内核通知用户何时可以启动一个 I/O 操作决定的。
异步 I/O 模型：在这种模型下，当一个描述符已准备好，可以启动 I/O 时，进程会通知内核。现在，并不是所有的系统都支持这种模型。

select介绍

更多的可以参考 > http://www.php.cn/linux-370682.html

select()和 poll()的 I/O 多路转接模型是处理 I/O 复用的一个高效的方法。它可以具体设置程序中每一个所关心的文件描述符的条件、希望等待的时间等，从 select()和 poll()函数返回时，内核会通知用户已准备好的文件描述符的数量、已准备好的条件等。通过使用 select()和 poll()函数的返回结果，就可以调用相应的 I/O 处理函数。

mark

小demo

#include <stdio.h>
#include <stdlib.h>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>
int
main(void)
{
    fd_set rfds;
    struct timeval tv;
    int retval;
   /* Watch stdin (fd 0) to see when it has input. */
    FD_ZERO(&rfds);
    FD_SET(0, &rfds);
   /* Wait up to five seconds. */
    tv.tv_sec = 5;
    tv.tv_usec = 0;
   retval = select(1, &rfds, NULL, NULL, &tv);
    /* Don't rely on the value of tv now! */
   if (retval == -1)
        perror("select()");
    else if (retval)
        printf("Data is available now.\n");
        /* FD_ISSET(0, &rfds) will be true. */
    else
        printf("No data within five seconds.\n");
   exit(EXIT_SUCCESS);
}

注意

当使用 select()函数时，存在一系列的问题，例如：内核必须检查多余的文件描述符，每次调用 select()
之后必须重置被监听的文件描述符集，而且可监听的文件个数受限制（使用 FD_SETSIZE 宏来表示
fd_set 结构能够容纳的文件描述符的最大数目）等。

引入电子书

这里的思路就是使用select监视两个输入,这里两个输入都是非阻塞的,最后监视使用永远阻塞

int AllInputDevicesInit(void)
{
    T_InputOp* now=T_InputOp_list;
    int iError = -1;
    FD_ZERO(&g_fd_set);
    while (now)
    {
        if (0 == now->Init())
        {
            FD_SET(now->fd, &g_fd_set);
            if (g_fd_max < now->fd)
            {
                g_fd_max = now->fd;
            }   
            iError = 0;
        }
        now = now->next;
    }
    g_fd_max+=1;
    return iError;
}
int GetInputEvent(T_InputEvent * out)
{
    T_InputOp* now=T_InputOp_list;
    int ret;
    fd_set read_fd_set=g_fd_set;
    // timeout=NULL 是永远等待,如果有数据才返回
    ret=select(g_fd_max, &read_fd_set, NULL, NULL, NULL);
    if(ret>0)
    {
        while (now)
        {
            if (FD_ISSET(now->fd, &read_fd_set))
            {
                if (0 == now->GetInputEventOp(out))
                {
                    return 0;
                }
                now = now->next;
            }
        }
    }
    return -1;
}