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

Question

我无法将协同程序链接在一起.在一个比hello world或factorial稍微不那么简单的例子中,我想要一个循环来持续监视文件修改时间,然后在触摸文件时打印出时间:

#!/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(异步迭代器):https://www.python.org/dev/peps/pep-0492/

Answer 1

我通过使用return而不是yield在链式协程中使用您的代码，就像链式协程示例一样：

#!/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 和语法让我自己有点困惑。以下是我发现有帮助的一些阅读材料：

• Python 3.3 中的新功能：“PEP 380：委派给子生成器的语法”
• PEP380：“形式语义”
• asyncio：“示例：链式协程”
• Greg Ewing 的“二叉树”示例