python - Tornado的异步非阻塞到底是怎么实现的呢？

Answer 1

关键词: Linux epoll

Answer 2

用了epoll kqueue这类IO多路复用的调用.

非阻塞这部分代码主要就在ioloop.py里

例如你要等待某个IO, 就往ioloop里注册一个handler, ioloop一直在运行(阻塞在epoll之类的调用上、但不会阻塞在某个IO上), 当其中某个io可读/可写的时候, ioloop会调用你注册的handler(例如 TCPServer 注册的_handle_connection)

注册handler可以看ioloop.py里 PollIOLoop 的 add_handler 函数
IOLoop的执行可以看 PollIOLoop 的 start 函数

其实至此已经具备了异步非阻塞的server。 gen、 future之类的库， 应该是为了简化异步代码的编写

Answer 3

Future 只是一个代理，本质上是一个异步任务，运行完成后把自己的运行结果保存在future 里。

tornado 的ioloop会循环检查每一个yield 出去的future ，在future 被设置为运行结束后，由于加上yield的函数是一个生成器，因此可以通过.send()对该函数设置yield的返回值，让程序回去继续执行，这样你就可以在代码中写类似于result = yield execute("select * from users")这样的代码了