简介

IO多路复用是指内核一旦发现进程指定的一个或者多个IO条件准备读取，它就通知该进程。IO多路复用适用如下场合：
　　（1）当客户处理多个描述字时（一般是交互式输入和网络套接口），必须使用I/O复用。
　　（2）当一个客户同时处理多个套接口时，而这种情况是可能的，但很少出现。
　　（3）如果一个TCP服务器既要处理监听套接口，又要处理已连接套接口，一般也要用到I/O复用。
　　（4）如果一个服务器即要处理TCP，又要处理UDP，一般要使用I/O复用。
　　（5）如果一个服务器要处理多个服务或多个协议，一般要使用I/O复用。
　　与多进程和多线程技术相比，I/O多路复用技术的最大优势是系统开销小，系统不必创建进程/线程，也不必维护这些进程/线程，从而大大减小了系统的开销。

函数原型

  1.   /* According to POSIX.1-2001, POSIX.1-2008 */
  2.        #include <sys/select.h>
  4.        /* According to earlier standards */
  5.        #include <sys/time.h>
  6.        #include <sys/types.h>
  7.        #include <unistd.h>
  8. /*函数原型*/
  9.        int select(int nfds, fd_set *readfds, fd_set *writefds,
  10.                   fd_set *exceptfds, struct timeval *timeout);
  12. nfds 为 max(fds)
  13. struct timeval *tv;
  14. int select(max(readfds), readfds, NULL,NULL,NULL,tv);

程序实例

循环读取单个文件

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. /* According to POSIX.1-2001, POSIX.1-2008 */
  4. #include <sys/select.h>
  6. /* According to earlier standards */
  7. #include <fcntl.h>
  8. #include <linux/input.h>
  9. #include <sys/stat.h>
  10. #include <sys/time.h>
  11. #include <sys/types.h>
  12. #include <unistd.h>
  14. #define filenamepath "/dev/input/event1"
  15. #define waittimeS (0x20)
  16. int main(int argc, char* argv[]) {
  17.   struct timeval tv;
  18.   /*数据读取buffer*/
  19.   struct input_event inputevent;
  20.   fd_set rfds;
  21.   /*打开需要读取的文件*/
  22.   int ReadFd = open(filenamepath, O_RDWR);
  23.   if (ReadFd < 0) {
  24.     perror("open");
  25.     exit(0);
  26.   }
  27.   /*must init*/
  28.   tv.tv_sec = waittimeS;
  29.   tv.tv_usec = 0;
  30.   FD_ZERO(&rfds);
  31.   /*Set The fds*/
  32.   FD_SET(ReadFd, &rfds);
  34.   for (;;) {
  35.     if (FD_ISSET(ReadFd, &rfds)) {
  36.       /*绑定需要读取数据的FD*/
  37.       int retval = pselect(ReadFd + 1, &rfds, NULL, NULL,
  38.                            (const struct timespec* restrict) & tv, NULL);
  40.       if (retval < 0) {
  41.         /*has error*/
  42.         perror("pselect\n");
  43.       } else if (retval == 0) {
  44.         /*timeout*/
  45.         /*超时以后，tv 将会被清零*/
  46.         tv.tv_sec = waittimeS;
  47.         tv.tv_usec = 0;
  48.         printf("timeout");
  49.       } else {
  50.         /*可以*/
  51.         int ret = read(ReadFd, &inputevent, sizeof(inputevent));
  52.         printf("inputevent.type %d\n", inputevent.type);
  53.       }
  55.     } else {
  56.       FD_SET(ReadFd, &rfds);
  57.       sleep(1);
  58.     }
  59.   }
  60.   (void)close(ReadFd);
  61. }

参考资料

select() - Unix, Linux System Call
linux select函数详解
Linux IO模式及 select、poll、epoll详解