异步函数调用

Question

我想学习如何在 Python3 中异步调用函数。我认为 Tornado 可以做到这一点。目前，我的代码在命令行上没有返回任何内容：

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

async def count(end):
    """Print message when start equals end."""
    start = 0
    while True:
        if start == end:
            print('start = {0}, end = {1}'.format(start, end))
            break
        start = start + 1

def main():

    # Start counting.
    yield count(1000000000)

    # This should print while count is running.
    print('Count is running. Async!')

if __name__ == '__main__':
    main()

谢谢

Answer 1

要调用异步函数，您需要提供一个事件循环来处理它。如果你有一个 Tornado 应用程序，它提供了这样一个循环，它允许你使你的处理程序异步：

from tornado.web import RequestHandler, url
from tornado.httpserver import HTTPServer
from tornado.ioloop import IOLoop


async def do_something_asynchronous():
    # e.g. call another service, read from database etc
    return {'something': 'something'}


class YourAsyncHandler(RequestHandler):

    async def get(self):
        payload = await do_something_asynchronous()
        self.write(payload)


application = web.Application([
    url(r'/your_url', YourAsyncHandler, name='your_url')
])

http_server = HTTPServer(application)
http_server.listen(8000, address='0.0.0.0')
IOLoop.instance().start()

在 Tornado 应用程序之外，您可以从任意数量的提供程序获取事件循环，包括内置 asyncio 库：

import asyncio
event_loop = asyncio.get_event_loop()
try:
    event_loop.run_until_complete(do_something_asynchronous())
finally:
    event_loop.close()

异步函数调用

Asynchronous Function Call

python

tornado