while true {

for i in stream[]; {

if i has data

read until unavailable

}

}

我们只要不停的把所有流从头到尾问一遍，又从头开始。这样就可以处理多个流了，但这样的做法显然不好，因为如果所有的流都没有数据，那么只会白白浪费CPU。阻塞模式下，内核对于I/O事件的处理是阻塞或者唤醒，而非阻塞模式下则把I/O事件交给其他对象。

kqueue与epoll非常相似，最初是2000年Jonathan Lemon在FreeBSD系统上开发的一个高性能的事件通知接口。注册一批socket描述符到 kqueue 以后，当其中的描述符状态发生变化时，kqueue 将一次性通知应用程序哪些描述符可读、可写或出错了。

kqueue的接口包括 kqueue()、kevent() 两个系统调用和 struct kevent 结构：

1. kqueue() 生成一个内核事件队列，返回该队列的文件描述符。其它 API 通过该描述符操作这个 kqueue。
2. kevent() 提供向内核注册 / 反注册事件和返回就绪事件或错误事件。
3. struct kevent 就是kevent()操作的最基本的事件结构。

struct kevent {

     uintptr_t ident;       /* 事件 ID */

     short     filter;       /* 事件过滤器 */

     u_short   flags;        /* 行为标识 */

     u_int     fflags;       /* 过滤器标识值 */

     intptr_t  data;         /* 过滤器数据 */

     void      *udata;       /* 应用透传数据 */

 };

在一个 kqueue 中，{ident, filter} 确定一个唯一的事件：

• ident

  事件的 id，一般设置为文件描述符。

• filter

  可以将 kqueue filter 看作事件。内核检测 ident 上注册的 filter 的状态，状态发生了变化，就通知应用程序。kqueue 定义了较多的 filter：

与socket读写相关的filter：

1. EVFILT_READ：TCP 监听 socket，如果在完成的连接队列 ( 已收三次握手最后一个 ACK) 中有数据，此事件将被通知。收到该通知的应用一般调用 accept()，且可通过 data 获得完成队列的节点个数。 流或数据报 socket，当协议栈的 socket 层接收缓冲区有数据时，该事件会被通知，并且 data 被设置成可读数据的字节数。
2. EVFILT_WRIT：当 socket 层的写入缓冲区可写入时，该事件将被通知；data 指示目前缓冲区有多少字节空闲空间。

 行为标志flags：

1. EV_ADD：指示加入事件到 kqueue
2. EV_DELETE：指示将传入的事件从 kqueue 中移除

　过滤器标识值：

1. EV_ENABLE：过滤器事件可用，注册一个事件时，默认是可用的。
2. EV_DISABLE：过滤器事件不可用，当内部描述可读或可写时，将不通知应用程序。

注册事件到 kqueue

bool Register(int kq, int fd)

{

      struct kevent changes[1];

      EV_SET(&changes[0], fd, EVFILT_READ, EV_ADD, 0, 0, NULL); 

      int ret = kevent(kq, changes, 1, NULL, 0, NULL); 

      return true;

} 

 Register 将 fd 注册到 kq 中。注册的方法是通过 kevent() 将 eventlist 和 neventlist 置成 NULL 和 0 来达到的。