zoukankan      html  css  js  c++  java
  • Tornado异步之-协程与回调

    回调处理异步请求

    • 回调 callback 处理异步官方例子
    # 导入所需库
    from tornado.httpclient import AsyncHTTPClient
    
    def asynchronous_fetch(url, callback):
        http_client = AsyncHTTPClient()
        def handle_response(response):
            callback(response.body)
        http_client.fetch(url, callback=handle_response)
    • http_client处理请求时http_client.fetch(url, callback=handle_response),参数url是请求的url, 关键字参数callback传入方法handle_response 此方法即为回调方法, 就是说当http_client请求完成后才会调用callback=handle_response中的 handle_response函数.
    • 请求网络是耗时操作,传入关键字参数callback来'表明'这是异步请求, 以此来确定这是异步处理请求

    协程处理异步

    from tornado import gen
    
    @gen.coroutine
    def fetch_coroutine(url):
        http_client = AsyncHTTPClient()
        response = yield http_client.fetch(url)
        raise gen.Return(response.body)
    • @gen.coroutine此装饰器代表的是协程, 与关键字yield搭配使用
    • http_client.fetch(url)请求网络是耗时操作, 通过关键字yield来挂起调用, 而当http_client.fetch(url)请求完成时再继续从函数挂起的位置继续往下执行.
    • raise gen.Return(response.body)在python3.3以后作用相当于return, 在python3.3之前作用是返回一个异常值, 跟 返回一个value, 以及python3.3之前generators不可以return value, 所以tornado定义了一个特殊的返回值raise gen.Return.
    • 在python3.3以后直接用return
     
     
  • 相关阅读:
    x-pack-crack
    ELK获取用户真实IP
    多层代理获取用户真实IP
    ELK帮助文档
    logstash filter plugin
    开源实时日志分析ELK平台部署
    消息队列集群kafka安装配置
    日志采集客户端 filebeat 安装部署
    rsync + inotify 同步
    【转】OpenWrt 防火墙/etc/config/firewall介绍
  • 原文地址:https://www.cnblogs.com/b02330224/p/10200162.html
Copyright © 2011-2022 走看看