在asyncio中链接协程（和观察者模式）

Question

我很难理解协同程序是如何链接在一起的。在一个比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（异步迭代器）：https://www.python.org/dev/peps/pep-0492/

Answer 1

正如其他人指出的那样，我的错误是，我试图像发电机一样使用协同程序。我需要创建多个协程，而不是依赖生成器进行迭代。此外，我需要使用任务来实现观察者模式，而不需要回调，因为多个注册者可以从同一个任务中产生。我的pathmonitor看起来像这样：

import os
import asyncio

class PathInfo:

    def __init__(self, path):
        self.path = path
        self.modtime = os.path.getmtime(path)
        self.startTask()

    def startTask(self):
        self.task = asyncio.async(self._checkIfTouched())

    def _checkIfTouched(self):
        while True:
            yield from asyncio.sleep(1)
            newtime = os.path.getmtime(self.path)
            if self.modtime != newtime:
                self.modtime = newtime
                return newtime

class PathMonitor:

    def __init__(self):
        self._info = {}

    @asyncio.coroutine
    def wasTouched(self, path):
        try:
            info = self._info[path]
        except KeyError:
            self._info[path] = info = PathInfo(path)
        if info.task.done():
            info.startTask()
        modtime = yield from info.task
        return modtime

def printer():
    while True:
        modtime = yield from mon.wasTouched('/tmp/myfile')
        print(modtime)

mon = PathMonitor()

loop = asyncio.get_event_loop()
asyncio.async(printer())
loop.run_forever()

Answer 2

我通过在链式协同路由中使用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()

请注意，打印机（）的循环将为每次迭代创建一个新的路径监视器生成器。不确定这是否是您想要的，但这可能是一个开始。

我发现协程API和语法让我自己有点困惑。以下是一些我觉得有用的阅读材料：

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