传递协程到AbstractEventLoop.call_later

Question

以下是我正在尝试使用的代码：

>>> import asyncio
>>> async def foo(loop, iv):
...     await asyncio.sleep(1, loop=loop)
...     print(f'done: {iv}')
...     
>>> loop = asyncio.get_event_loop()
>>> loop.call_later(2, foo, loop, 10)
<TimerHandle when=36395.554089349 foo(<_UnixSelecto...e debug=False>, 10) at <input>:1>
>>> loop.run_forever()

（Python 3.6）

基本上，foo（）函数有一些链式的async调用，所以这个方法必须是async，因为需要等待链式调用。然而，此方法是在延迟后触发的，当运行此代码时，会出现以下问题：

/usr/lib64/python3。6/异步IO/事件。py:127:RuntimeWarning:coroutine'foo'从未被期待过_回调（*self.\u args）

在以后的call\u中处理此async调用的正确方法是什么？

Answer 1

call\u later（）仅支持回调（常规函数）；你根本无法通过一个合作项目。

如果您想延迟协程，您有两个选项；要么通过让协程在开始时Hibernate来延迟协程，要么从call_later（）调用asyncio.create_task（）安排它运行。

使用asyncio。sleep（）在例程开始时，可以让循环直接执行它：

async def foo(iv):
    # delay start of the work
    await asyncio.sleep(2)

    # rest of your coroutine

您可以很容易地使用包装器协程来实现这一点：

async def await_coro_later(delay, coro, *args, **kwargs):
    await asyncio.sleep(delay)
    await coro(*args, **kwargs)

如果您使用asyncio。创建任务（）

# create a task for foo(10) later
loop.call_later(2, asyncio.create_task, foo(10))

任何一种技术的演示：

>>> import asyncio
>>> async def foo(iv, start):
...     await asyncio.sleep(1)
...     offset = asyncio.get_running_loop().time() - start
...     print(f'done ({offset:.3f}s): {iv}')
...
>>> async def await_coro_later(delay, coro, *args, **kwargs):
...     await asyncio.sleep(delay)
...     await coro(*args, **kwargs)
...
>>> async def demo():
...     loop = asyncio.get_running_loop()
...     start = loop.time()
...     loop.call_later(2, asyncio.create_task, foo('cb_to_create_task', start))
...     await await_coro_later(5, foo, 'coro_later', start)
...
>>> asyncio.run(demo())
done (3.004s): cb_to_create_task
done (6.006s): coro_later