tornado异步

同步：

含义：指两个或两个以上随时间变化的量在变化过程当中保持必定的相对关系

现象：有一个共同的时钟，按来的顺序一个一个处理

直观感觉 ：就是须要等候，效率低下

异步：

含义 ：双方不须要共同的时钟，也就是接收方不知道发送方何时发送，因此在发送的信息中就要有提示接收方开始接收的信息，如开始位，同时在结束时有中止位

现象：没有共同的时钟，不考虑顺序来了就处理

直观感觉：就是不用等了，效率高

阻塞调用：

含义 ： 阻塞调用是指调用结果返回以前，当前线程会被挂起（线程进入非可执行状态，在这个状态下，CPU不会给线程分配时间片，即线程暂停运行）。函数只有在获得结果以后才会返回

现象：读套接字时没有数据等数据来，写套接字时写不下了也一直等，等能写下了往里写（套接字被写满的缘由不在本地，在于网络另外一头的套接字被写满了来不及读出去，致使本地的套接字内容来发不出去堵住了）

直观感觉：执着

非阻塞调用：

含义 ：非阻塞调用是指没有调用结果当即返回，当前线程不被挂起，能够继续作其它工做

现象：读套接字时没有数据，不等直接返回干别的事去，写套接字写不下了也不写了，直接返回干别的事去

直观感觉：勤奋

手动实现异步：

import threading
import time
#回调函数实现异步
#2.携程实现异步
#返回数据的时候使用了不一样的方式
# 在tornado里面，把这些方式封装成了装饰器
#想使用异步的时候，加上这些装饰器，就能够实现异步
# epoll 加携程实现异步   异步非阻塞框架，tornado

def func(on_finish):
    def inner(on_finish):
        print('----start----')
        time.sleep(5)
        print('----end----')
        on_finish('hello world')  #回调函数
        # yield 'helloworld'  #改为携程yield

    threading.Thread(target=inner,args=(on_finish,)).start()  #改为epoll

#原来使用return返回数据，可是他有瓶颈，咱们使用一个函数来返回数据

def on_finish(result):
    print(result)

func(on_finish)
time.sleep(2)
print('---------b---------')

函数执行结果以下：

 

异步编程：不少方法tornado 6.0版本已经不能使用，下面列举两种可用的

第一种：经过协程来实现异步(使用requests模块)

第一步：安装模块　　

pip install futures
pip install requests

第二步：导入模块

from tornado.concurrent import run_on_executor 
from concurrent.futures import ThreadPoolExecutor 
import requests

代码以下：

class ReqHandler(RequestHandler):
    '''经过携程来实现异步（使用requests模块）'''
    executor = ThreadPoolExecutor()
    @tornado.gen.coroutine  #携程装饰器
    def get(self):
        response = yield self.func()
        self.write(response.text)

    @run_on_executor
    def func(self):
        res = requests.get('http://127.0.0.1:8000/sync?id=2') #异步的客户端
        return res

第二种：

官方推荐的方法：

class GenHandler(RequestHandler):
    '''当前版本官方推荐的异步案例'''
    @tornado.gen.coroutine  #添加异步装饰器
    def get(self):
        client = AsyncHTTPClient() #异步的客户端
        response = yield client.fetch('http://127.0.0.1:8000/sync')
        self.write(response.body) #获取请求参数