async def和coroutines，链接是什么-Java 学习之路

我试图围绕Python3中出现的新的asyncio功能 .

我从一个在stackoverflow上找到的简单工作者示例开始，修改了一下：

import asyncio, random

q = asyncio.Queue()

@asyncio.coroutine
def produce(name):
    while True:
        value = random.random()
        yield from q.put(value)
        print("Produced by {0}".format(name))
        yield from asyncio.sleep(1.0 + random.random())

@asyncio.coroutine
def consume(name):
    while True:
        value = yield from q.get()
        print("Consumed by {0} ({1})".format(name, q.qsize()))
        yield from asyncio.sleep(1.2 + random.random())

loop = asyncio.get_event_loop()
loop.create_task(produce('X'))
loop.create_task(produce('Y'))
loop.create_task(consume('A'))
loop.create_task(consume('B'))
loop.run_forever()

我大多理解它是如何工作的（除了 yield from asyncio.sleep() 之外......它是一个委托但是阻塞函数的占位符吗？它在哪里屈服？）

但是，最重要的是，我如何将此示例转换为使用新的花式 async def 和 await 关键字？那会有什么好处？

2 回答

3
只需更换
```
@asyncio.coroutine
def f(arg)
```
同
```
async def f(arg)
```
和 yield from ，代码中包含 await .

另请阅读PEP 412关于 async with 和 async for .
回复于 2024-05-14T10:19:22+08:00
2

这篇文章是我发现最有帮助的 .

http://www.snarky.ca/how-the-heck-does-async-await-work-in-python-3-5

回复于 2024-05-14T10:19:22+08:00

async def和coroutines，链接是什么

2 回答

相关问题