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

素材狗 2022-01-01 14:07:25 文章分类：Python问题点击数：1次

文章标签

chaining coroutines in asyncio (and observer pattern)(在异步(和观察者模式)中链接协程)

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

问题描述

我很难理解协程是如何链接在一起的。在一个比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/

推荐答案

我在链接的协程中使用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()