3

我curio用来实现使用curio.Event对象进行通信的两个任务的机制。第一个任务（称为action()）首先运行，并且awaits要设置的事件。第二个任务（称为setter()）在第一个任务之后运行，并且正在设置事件。

代码如下：

import curio

evt = curio.Event()


async def action():
    await evt.wait()
    print('Performing action')


async def setter():
    await evt.set()
    print('Event set')


async def run():
    task = await curio.spawn(action())
    await setter()
    print('Finished run')
    await task.wait()


curio.run(run())

输出如下：

Event set
Finished run
Performing action

这意味着在print('Performing action')AFTER 执行print('Finished run')，这就是我试图阻止的 - 我期望调用await evt.set()也会调用它的所有服务员，并且在调用所有服务员run()之前不会继续，这意味着action()将继续 BEFOREprint('Finished run')是执行。这是我想要的输出：

Event set
Performing action
Finished run

我怎么了？有没有办法改变这种行为？我想对执行顺序有更多的控制权。

谢谢

4

1 回答 1

1

设置Event是一种表示发生了某事的方式：正如您已经指出的那样，它不提供对服务员的调用。

如果要在执行操作后报告运行完成，则应在等待操作后报告：

async def run():
    task = await curio.spawn(action())
    await setter()
    await task.wait()  # await action been performed
    print('Finished run')  # and only after that reporting run() is done

如果您想阻止执行run()直到某事发生，您可以使用另一个事件wait()来set()执行此操作：

import curio

evt = curio.Event()
evt2 = curio.Event()


async def action():
    await evt.wait()
    print('Performing action')
    await evt2.set()
    print('Event 2 set')


async def setter():
    await evt.set()
    print('Event set')


async def run():
    task = await curio.spawn(action())
    await setter()    
    await evt2.wait()
    print('Finished run')
    await task.wait()


curio.run(run())

回复：

Event set
Performing action
Event 2 set
Finished run
于 2019-06-07T00:18:36.647 回答