多输入select

时间:2023-03-08 21:42:32

title: 多输入select

date: 2019/3/20 17:21:34

toc: true

多输入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 处理函数。

多输入select

多输入select

小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;
}