update

Author: zhyq0826

book/ch05.md

@@ -1,4 +1,4 @@
-## 5 多路复用技术
+## 5. 多路复用技术
 
 ### 5.1 为什么需要 IO 多路复用技术？
 
@@ -61,14 +61,17 @@ IO 多路复用技术会涉及到以下几种 IO 模型的讨论，他们分别
 
 ![](imgs/io-multiplex-model.png)
 
-![](imgs/signal-io-model.png)
-
 #### 5.4.4 信号驱动 IO
 
 同 IO 多路复用技术，内核通过信号通知我们的 IO 何时就绪。
 
-![](imgs/asynchronous-io-model.png)
+![](imgs/signal-io-model.png)
 
 #### 5.4.5 Asynchronous IO
 
-同信号驱动 IO，内核通过信号通知我们的 IO 何时就绪，区别在于信号驱动 IO 通知发生在数据开始拷贝时，而异步 IO 通知在数据已经完成从内核到用户进程的拷贝。
+同信号驱动 IO，内核通过信号通知我们的 IO 何时就绪，区别在于信号驱动 IO 通知发生在数据开始拷贝时，而异步 IO 通知在数据已经完成从内核到用户进程的拷贝。
+
+![](imgs/asynchronous-io-model.png)
+
+在接下来的几个小节会对 linux 提供的几种 IO 多路复用技术一一进行介绍，他们分别是 select、poll、epoll。
+

book/ch06.md

@@ -1,12 +1,12 @@
-# IO 多路复用之 select 
+## 6. IO 多路复用之 select 
 
-> 上一节我们介绍了 IO 多路复用的技术，这一节我们说说其中的 select。
+这一节我们说说 O 多路复用的技术 select。
 
-## select 是什么
+### 6.1 select 是什么
 
 select 是 linux 内核提供的函数，它允许同时监听多个文件描述符的读写事件，在这些事件中有一个或多个变得可用之后以及经历一段指定的时间之后通知用户进程。
 
-## 使用 select
+### 6.2 使用 select
 
 Python 中提供了 select 模块来调用系统的 select 函数：
 ```python
@@ -22,7 +22,7 @@ server_address = ('localhost', 8000)
 server.bind(server_address)
 server.listen(10)
 ```
-注意在上面的代码中，我们设置了当前的 socket 为非阻塞的 **server.setblocking(0)**，在 web server 中我们始终有一个 socket 是来监听的新的 socket 连接，因而这个监听 socket 要加入读事件队列：
+注意在上面的代码中，我们设置了当前的 socket 为非阻塞的 **server.setblocking(0)**，在 Web Server 中我们始终有一个 socket 是来监听的新的 socket 连接，因而这个监听 socket 要加入读事件队列：
 ```python
 inputs = [server]
 ```
@@ -37,11 +37,16 @@ message_queues = {}
 while inputs:
     readable, writable, exceptional = select.select(inputs, outputs, inputs)
 ```
-select 函数返回三个文件描述符列表，分别代表有**可读事件列表，有可写事件列表，有异常事件列表**，返回这些事件列表包含我们作为 select 参数的那些文件描述符。
+select 函数返回三个文件描述符列表，分别代表有**可读事件列表，有可写事件列表，有异常事件列表**，返回的这些事件列表中包括了我们作为 select 参数的那些文件描述符。
 
-## 读事件列表
+### 6.3 读事件列表
+
+读事件列表根据不同的情形有如下三种处理方式。
+
+**情形一**
+
+如果一个文件描述符可读，而且这个文件描述符恰巧就是我们刚才创建的 server，说明我们侦听的 socket **有新的连接请求**：
 
-**情形一**，如果一个文件描述符可读，而且这个文件描述符恰巧就是我们刚才创建的 server，说明我们侦听的 socket 有新的连接请求了：
 ```python
 for s in readable:
     if s is server:
@@ -50,9 +55,12 @@ for s in readable:
         inputs.append(connection)
         message_queues[connection] = Queue.Queue()
 ```
-在上面的代码中，我们通过 accept 函数获得新的连接，并且把该连接加入 inputs 列表，等待连接到该 connection 的客户端发送数据，在此我们也给这个新的 connection 一个写消息的队列。
+在上面的代码中，我们通过 accept 函数获得新的连接，并且把该连接加入 inputs 列表，等待连接到该 connection 的 client 发送数据，在此我们也给这个新的 connection 创建一个写消息的队列。
+
+**情形二**
+
+如果一个描述符不是侦听 socket 说明这个描述符**有数据可读**，此时我们可以使用 `recv` 来读取数据：
 
-**情形二**，如果一个描述符不是侦听 socket 说明这个描述符有数据可读，此时我们可以使用 `recv` 来读取数据：
 ```python
 else:
     data = s.recv(1024)
@@ -62,7 +70,10 @@ else:
         message_queues[s].put(data.capitalize())
 ```
 
-**情形三**，如果读取的数据是空的，说明 client 关闭了这个连接，我们需要把这个连接从我们的监控列表中移除，并且释放对应的资源：
+**情形三**
+
+如果读取的数据是空的，说明 client 关闭了这个连接，我们需要把这个连接从我们的监控列表中移除，并且释放对应的资源：
+
 ```python
 else:
     if s in outputs:
@@ -71,7 +82,7 @@ else:
     s.close()
 ```
 
-## 写事件列表
+### 6.4 写事件列表
 
 对于写事件列表来说，在这个例子中需要处理的事情比较有限，如果这个描述符有数据要发送，则通过 `send` 函数发送数据：
 ```python
@@ -85,7 +96,7 @@ for s in writable:
         s.send(next_msg)
 ```
 
-## 异常列表
+### 6.5 异常列表
 
 最后是异常列表，说明描述符有错误发生，关闭它们并且释放资源：
 ```python
@@ -97,7 +108,7 @@ for s in exceptional:
     del message_queues[s]
 ```
 
-## select 的超时设置
+### 6.6 select 的超时设置
 
 select 的超时设置有以下三种情形：
 
@@ -113,9 +124,9 @@ select 的超时设置有以下三种情形：
 
 不等待，检查完描述符之后立即返回，此时参数是 0 
 
-## select 的问题
+### 6.7 select 的问题
 
-select 是早期 linux 内核提供的多路复用技术，并且伴随着 linux 设计的限制，自身也有这些不足：
+select 是早期 linux 内核提供的多路复用技术，并且伴随着 linux 设计的限制，自身也有些不足：
 1. select 有最大监听描述符限制
 2. select 是通过逐个扫描的方式获取有事件的描述符
 3. 在多线程环境下，select 的表现不尽如人意

book/ch07.md

@@ -1,13 +1,13 @@
-# IO 多路复用之 poll
+## 7. IO 多路复用之 poll
 
-> 上一节我们介绍了 IO 多路复用的技术的 select，这一节我们说说 poll。
+这小节我们介绍 IO 多路复用技术的 poll。
 
-## poll 是什么
+### 7.1 poll 是什么
 
 poll 是类似于 select 的又一个 linux 提供的内核函数，但是 poll 的底层实现和 select 相比更高效，更详细的差异后面的章节会讲到。
 
 
-## 使用 poll
+### 7.2 使用 poll
 
 Python 中 poll 的实现同样也在 select module 中，但是不同于 select，poll 是通过主动注册文件描述符和事件实现对文件描述符的监听，而且 poll 提供了一些列的事件 flag 来进行对应的事件注册：
 
@@ -26,9 +26,9 @@ Python 中 poll 的实现同样也在 select module 中，但是不同于 select
         <tr><td>POLLHUP</td> <td>Hung up</td></tr>
         <tr><td>POLLNVAL</td> <td>Invalid request: descriptor not open</td></tr>
     </tbody>
-
 </table>
 
+
 同上文中 select 的例子一样，我们使用 poll 创建一个回显服务，区别是 poll 需要主动注册文件描述符和需要监听的事件：
 ```python
 
@@ -59,11 +59,14 @@ while True:
         pass
 ```
 
-## 读事件 POLLIN 和 POLLPRI
+### 7.3 读事件 POLLIN 和 POLLPRI
 
 poll 的读事件对应的是 **POLLIN** 和 **POLLPRI** ，同 select 读事件一样也有以下的几种情形。
 
-**情形一**，如果文件描述符是 server，说明有新的连接到来，在获取这个连接之后需要把新的连接通过 poll 来进行注册，这样我们就可以监听新连接的事件了：
+**情形一**
+
+如果文件描述符是 server，说明有新的连接到来，在获取这个连接之后需要把新的连接通过 poll 来进行注册，这样我们就可以监听新连接的事件了：
+
 ```python
 
 if s is server:
@@ -75,7 +78,10 @@ if s is server:
     message_queues[connection] = Queue.Queue()
 ```
 
-**情形二**，如果文件描述符不是 server，说明这个文件描述符有数据可读，此时我们可以使用 `recv` 来读取数据：
+**情形二**
+
+如果文件描述符不是 server，说明这个文件描述符有数据可读，此时我们可以使用 `recv` 来读取数据：
+
 ```python
 else:
     data = s.recv(1024)
@@ -86,7 +92,10 @@ else:
 ```
 与此同时，我们也需要修改这个文件描述符需要被监听的事件类型，在读完数据之后我们需要进行数据回显，因此修改事件类型为 `READ_WRITE`，这点与 select 不同。
 
-**情形三**，如果读取的数据是空的，说明 client 关闭了这个连接，我们需要把这个连接从 poll 的注册列表中移除，并且释放对应的资源：
+**情形三**
+
+如果读取的数据是空的，说明 client 关闭了这个连接，我们需要把这个连接从 poll 的注册列表中移除，并且释放对应的资源：
+
 ```python
 poller.unregister(s)
 s.close()
@@ -95,10 +104,10 @@ s.close()
 del message_queues[s]
 ```
 
-## 写事件 POLLOUT
+### 7.4 写事件 POLLOUT
 
 对有写事件的文件描述符的处理和 select 类似，区别在于如果没有消息可写，我们修改描述符的监听事件为 `READ_ONLY`：
-```
+```python
 elif flag & select.POLLOUT:
     try:
         next_msg = message_queues[s].get_nowait()
@@ -108,7 +117,7 @@ elif flag & select.POLLOUT:
         s.send(next_msg)
 ```
 
-## 异常处理 POLLHUP 和 POLLERR
+### 7.5 异常处理 POLLHUP 和 POLLERR
 
 `POLLHUP` 说明 client 没有正确关闭连接，`POLLERR` 说明有错误发生，这两种情形我们选择取消对文件描述符的监听，并且释放资源：
 ```python
@@ -120,7 +129,7 @@ s.close()
 del message_queues[s]
 ```
 
-## poll 和 select 的对比
+### 7.6 poll 和 select 的对比
 
 select 和 poll 都支持同时监听多个文件描述符，但是他们有着显著的区别。