为了回答最初提出的问题,不需要close()
运行循环,您可以对整个程序重用同一循环。
给定更新中的代码,您queue_manager
可能会像这样:
try:
self.loop.run_until_complete(future)
except Exception as e:
self.check_in_records()
self.reconnect()
self.start_job()
取消future
是没有必要的,据我所知没有任何作用。这不同于专门对做出反应的参考答案KeyboardInterrupt
,特别是因为它是由asyncio本身引发的。KeyboardInterrupt
可以run_until_complete
在将来尚未真正完成的情况下进行传播。Ctrl-C
在asyncio中正确处理是非常困难的,甚至是不可能的(有关详细信息,请参见此处),但是幸运的是,问题根本不Ctrl-C
存在,而是协程引发的异常。(请注意,KeyboardInterrupt
它不会继承自Exception
,因此,Ctrl-C
除非主体不执行。)
我取消了未来,因为在这种情况下,还有其他待处理的任务,并且我想从本质上删除那些任务并开始一个新的事件循环。
这是一件正确的事情,但是(已更新)问题中的代码仅取消了一个已传递给的未来run_until_complete
。回想一下,future是将在以后提供的结果值的占位符。提供该值后,可以通过调用进行检索future.result()
。如果将来的“价值”是一个例外,future.result()
将引发该例外。run_until_complete
具有约定,它将在给定的未来产生值之前一直运行事件循环,然后返回该值。如果“值”实际上是要提高的例外,run_until_complete
则将重新提高它。例如:
loop = asyncio.get_event_loop()
fut = loop.create_future()
loop.call_soon(fut.set_exception, ZeroDivisionError)
# raises ZeroDivisionError, as that is the future's result,
# manually set
loop.run_until_complete(fut)
当所讨论的future实际上是a时Task
,一个特定于异步的对象将协程包装为aFuture
,这种future的结果就是协程返回的对象。如果协程引发异常,则检索结果将重新引发它,因此run_until_complete
:
async def fail():
1/0
loop = asyncio.get_event_loop()
fut = loop.create_task(fail())
# raises ZeroDivisionError, as that is the future's result,
# because the coroutine raises it
loop.run_until_complete(fut)
处理任务时,run_until_complete
完成意味着协程也已经完成,返回值或引发异常(由run_until_complete
返回或引发确定)。
另一方面,取消任务的工作方式是安排要恢复的任务以及将await
其挂起的表达式提高CancelledError
。除非任务专门捕获并抑制了此异常(行为良好的异步代码不应该这样做),否则该任务将停止执行,并且CancelledError
将成为其结果。但是,如果协程在cancel()
被调用时已经完成,那么cancel()
将无能为力,因为没有待处理await
的注入CancelledError
。