在异步(和观察者模式)中链接协程

本文介绍了在异步(和观察者模式)中链接协程的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

我很难理解协程是如何链接在一起的。在一个比hello world或factorials稍微简单一点的示例中，我希望有一个循环，它持续监视文件修改时间，然后在每次接触文件时打印出时间：

#!/usr/bin/env python3 import os import asyncio @asyncio.coroutine def pathmonitor(path): modtime = os.path.getmtime(path) while True: new_time = os.path.getmtime(path) if new_time != modtime: modtime = new_time yield modtime yield from asyncio.sleep(1) @asyncio.coroutine def printer(): while True: modtime = yield from pathmonitor('/home/users/gnr/tempfile') print(modtime) loop = asyncio.get_event_loop() loop.run_until_complete(printer()) loop.run_forever()

我预计这会起作用-但是，当我运行它时，我得到一个：

RuntimeError: Task got bad yield: 1426449327.2590399

我在这里做错了什么？

更新：有关观察者模式的示例(即，在不使用回调(您必须使用任务)的情况下有效地允许多个注册者获取更新)，请参阅下面的答案。

UPDATE2：对此有更好的修复：3.5的async for(异步迭代器)：www.python/dev/peps/pep-0492/

推荐答案

我在链接的协程中使用return而不是yield使您的代码正常工作，就像chained coroutines example：

#!/usr/bin/env python3 import os import asyncio2 @asyncio.coroutine def pathmonitor(path): modtime = os.path.getmtime(path) while True: new_time = os.path.getmtime(path) if new_time != modtime: modtime = new_time return modtime yield from asyncio.sleep(1) @asyncio.coroutine def printer(): while True: modtime = yield from pathmonitor('/tmp/foo.txt') print(modtime) loop = asyncio.get_event_loop() loop.run_until_complete(printer()) loop.run_forever()

请注意，printer()的循环将为每个迭代创建一个新的pathmonitor生成器。不确定这是否是您想要的生成器，但这可能是一个开始。

我自己觉得协程API和语法有点混乱。以下是我觉得有帮助的一些读物：

• What’s New In Python 3.3: "PEP 380: Syntax for Delegating to a Subgenerator"
• PEP380: "Formal semantics"
• asyncio: "Example: Chain coroutines"
• Greg Ewing's "Binary Tree" example