当前位置: 首页>行业 >

环球快资讯丨Python 异步: 使用和查询任务(8)

来源: 腾讯云 | 时间: 2023-02-16 21:19:12 |

任务是异步程序的货币。在本节中,我们将仔细研究如何在我们的程序中与它们交互。

1. 任务生命周期

异步任务具有生命周期。首先,任务是从协程创建的。然后安排在事件循环中独立执行。在某个时候,它会运行。

在运行时它可能会被挂起,例如等待另一个协程或任务。它可能正常完成并返回结果或因异常而失败。


(相关资料图)

另一个协程可能会介入并取消任务。最终,它将完成并且无法再次执行。

我们可以将这个生命周期总结如下:

创建预定取消运行暂停结果Exception取消完成

请注意,Suspended、Result、Exception 和 Canceled 本身并不是状态,它们是正在运行的任务的重要转换点。

下图总结了此生命周期,显示了每个阶段之间的转换。

现在我们已经从高层次上熟悉了任务的生命周期,让我们仔细看看每个阶段。

2. 如何检查任务状态

创建任务后,我们可以检查任务的状态。我们可能要检查两种状态,它们是:

任务是否完成任务是否取消

让我们依次仔细看看每一个。

2.1. 检查任务是否完成

我们可以通过 done() 方法检查任务是否完成。如果任务完成,该方法返回 True,否则返回 False。

# check if a task is doneif task.done():# ...

如果任务有机会运行但现在不再运行,则该任务已完成。已安排的任务未完成。同样,正在运行的任务未完成。

如果出现以下情况,则完成任务:

协程正常结束。协程显式返回。协程中出现意外错误或异常任务被取消。

2.2. 检查任务是否取消

我们可以通过 cancelled() 方法检查任务是否被取消。如果任务被取消,该方法返回 True,否则返回 False。

...# check if a task was canceledif task.cancelled():# ...

如果在任务上调用 cancel() 方法并成功完成,则任务被取消,例如 cancel() 返回 True。

如果未调用 cancel() 方法,或者调用了 cancel() 方法但未能取消任务,则不会取消任务。

3. 如何获取任务结果

我们可以通过 result() 方法获取任务的结果。这将返回由 Task 包装的协程的返回值,如果包装的协程没有显式返回值,则返回 None 。

...# get the return value from the wrapped coroutinevalue = task.result()

如果协程引发未处理的错误或异常,则在调用 result() 方法时会重新引发,并且可能需要处理。

...try:# get the return value from the wrapped coroutinevalue = task.result()except Exception:# task failed and there is no result

如果任务被取消,则在调用 result() 方法时会引发 CancelledError 异常,可能需要进行处理。

...try:# get the return value from the wrapped coroutinevalue = task.result()except asyncio.CancelledError:# task was canceled

因此,最好先检查任务是否已取消。

...# check if the task was not canceledif not task.cancelled():# get the return value from the wrapped coroutinevalue = task.result()else:# task was canceled

如果任务尚未完成,则在调用 result() 方法时会引发 InvalidStateError 异常,可能需要进行处理。

...try:# get the return value from the wrapped coroutinevalue = task.result()except asyncio.InvalidStateError:# task is not yet done

因此,最好先检查任务是否已完成。

...# check if the task is not doneif not task.done():await task# get the return value from the wrapped coroutinevalue = task.result()

4. 如何获取任务异常

任务包装的协程可能会引发未处理的异常。这实际上会取消任务。

我们可以通过 exception() 方法在任务包装的协程中检索未处理的异常。

...# get the exception raised by a taskexception = task.exception()

如果包装协程中未引发未处理的异常,则返回 None 值。

如果任务被取消,则在调用 exception() 方法时会引发 CancelledError 异常,可能需要对其进行处理。

...try:# get the exception raised by a taskexception = task.exception()except asyncio.CancelledError:# task was canceled

因此,最好先检查任务是否已取消。

...# check if the task was not canceledif not task.cancelled():# get the exception raised by a taskexception = task.exception()else:# task was canceled

如果任务尚未完成,则在调用 exception() 方法时会引发 InvalidStateError 异常,可能需要进行处理。

...try:# get the exception raised by a taskexception = task.exception()except asyncio.InvalidStateError:# task is not yet done

因此,最好先检查任务是否已完成。

...# check if the task is not doneif not task.done():await task# get the exception raised by a taskexception = task.exception()

5. 如何取消任务

我们可以通过 cancel() 方法取消计划任务。如果任务被取消,则 cancel 方法返回 True,否则返回 False。

...# cancel the taskwas_cancelled = task.cancel()

如果任务已经完成,则无法取消,cancel() 方法将返回 False,任务不会处于已取消状态。

下次任务有机会运行时,它将引发 CancelledError 异常。如果 CancelledError 异常未在包装协程内处理,任务将被取消。否则,如果在包装协程内处理了 CancelledError 异常,任务将不会被取消。

cancel() 方法还可以接受一个消息参数,该参数将在 CancelledError 的内容中使用。

6. 如何在任务中使用回调

我们可以通过 add_done_callback() 方法向任务添加完成回调函数。此方法采用任务完成时要调用的函数的名称。回调函数必须将 Task 实例作为参数。

# done callback functiondef handle(task):print(task) ...# register a done callback functiontask.add_done_callback(handle)

回想一下,当包装的协程返回时正常完成、引发未处理的异常或取消任务时,任务可能会完成。add_done_callback() 方法可用于添加或注册任意数量的 done 回调函数。

我们还可以通过 remove_done_callback() 函数删除或注销回调函数。

...# remove a done callback functiontask.remove_done_callback(handle)

7. 如何设置任务名称

一个任务可能有一个名字。如果多个任务是从同一个协程创建的,那么这个名称会很有用,我们需要一些方法以编程方式区分它们。当通过“名称”参数从协程创建任务时,可以设置名称。

...# create a task from a coroutinetask = asyncio.create_task(task_coroutine(), name="MyTask")

任务的名称也可以通过 set_name() 方法设置。

...# set the name of the tasktask.set_name("MyTask")

我们可以通过 get_name() 方法检索任务的名称。

...# get the name of a taskname = task.get_name()

关键词: 编程算法

 

热文推荐

透视雪佛兰大降价的幕后:销量低迷,八月无一辆车的销量破万

继上汽通用别克开启限时优惠之后,雪佛兰也按捺不住了。科鲁泽(参数|询

2023-09-09

茵郁道馆(关于茵郁道馆简述)

,你们好,今天0471房产来聊聊一篇郁道馆,郁道馆简述的文章,网友们对

2023-09-09

“这学还怎么上”?某小学开学一年级有43个班,家长哭诉卷不动了

“这学还怎么上”?某小学开学一年级有43个班,家长哭诉卷不动了,初中,

2023-09-09

夏东豪身高(夏东豪和谁牵手成功)

来为大家解答以上的问题。夏东豪身高,夏东豪和谁牵手成功这个很多人还

2023-09-09

莲台寺(关于莲台寺的简介)

1、莲台寺始建于唐朝,几经兴衰,因唐高僧智诜和尚曾主持莲台寺,在国

2023-09-09

首日产生14枚金牌!2023年全国青年(U20)田径锦标赛在我市开赛

9月8日上午2023年全国青年(U20)田径锦标赛在大庆市体育场开赛据了解

2023-09-09

“叫我们大队的人来”,女子理发店亮证件威胁老板!官方通报

据@郯城发布微博,郯城县联合调查组发布9月8日情况通报称,针对网传“

2023-09-08

龙虎榜|蓝英装备今日涨停,上榜营业部席位合计净买入9230.88万元

9月8日,蓝英装备今日涨停,龙虎榜数据显示,上榜营业部席位全天成交1

2023-09-08

古代皇帝用什么语言

古代皇帝用什么语言1、古代皇帝用什么语言当时的官话,也是官方语言;

2023-09-08

又大跌!再度跌破20万

碳酸锂又处于新一轮价格下滑周期中。

2023-09-08

记录走过半个世纪的爱情,金山石化街道开展“金婚摄影”活动

“叔叔,再靠近阿姨一点”“阿姨,动作再俏皮一点,对,看镜头!”随着

2023-09-08

苦茶随笔(关于苦茶随笔简述)

,你们好,今天0471房产来聊聊一篇茶随笔,茶随笔简述的文章,网友们对

2023-09-08

河南修武县属于哪个市(焦作修武县地理位置及经济发展情况)

河南修武县作为焦作市的一个县级行政区,处于中部偏东区域,是河南省发

2023-09-08

第十一届环鄱赛开赛 30多个国家及港澳台地区选手参赛

中新网上饶9月8日电 (记者 吴鹏泉)第十一届环鄱阳湖国际自行车大

2023-09-08

iPhone 15系列曝光:15 Plus首发4800万主摄

iPhone15系列即将发布,据新爆料,该系列将有三种不同的影像规格。iPhone

2023-09-08

电脑自带的酷狗音乐是在哪个盘里_电脑酷狗怎么在我的电脑显示酷狗音乐云盘

电脑自带的酷狗音乐是在哪个盘里,电脑酷狗怎么在我的电脑显示酷狗音乐

2023-09-08

佛山五区均升级暴雨红色预警:各中小学、幼儿园已停课,部分景区已闭园

南方财经全媒体记者吴蓉佛山报道受台风“海葵”残余环流和季风影响,9

2023-09-08

谭惜陆离电视剧完结了吗

谭惜和陆离结婚三年,这三年里,陆离身边的女人从未重复过,直到谭惜和

2023-09-08

北京再推介近2000亿元项目引资民间

从引入民间资本参与方式看,民间资本参与方式更加多元化。具体来看,民

2023-09-08

首脑(首脑)

导读1、词语:首脑拼音:shǒunǎo词性:名词近义词:元首、领袖、首领

2023-09-01

资讯

胡松辉:澳门特区正在努力争取承办CBA赛事

昨晚,第六届粤澳杯第二回合的比赛在恩平体育中心落下帷幕,广东队以89∶77赢下比赛。两回合比赛,广东队以177∶160的优势获得本届比赛的冠

2022-07-08     
北京推出14条秋游文化线路

金秋时节,北京市文化和旅游局以赏银杏品文化为主题,推出14条“叶落的季节——漫步北京赏银杏品文化主题线路”,邀市民和游客以步行、骑行

2021-10-27     
基因编辑发力 培育高质量人源化供体猪

此次人体试验,仅仅验证了基因编辑猪克服异种器官移植的超急性排斥反应,还需解决延迟性排斥反应、消耗性血栓等问题。但通过这次试验,能更

2021-10-27     
中国经济高质量发展步伐稳健 长期向好基本面未变

在全球疫情走势和经济走势趋于复杂的背景下,中国经济巨轮将驶向何方,举世关注。2020年10月26日至29日,党的十九届五中全会在京举行,明确

2021-10-27     
南美解放者杯决赛允许近4.5万观众入场

南美洲足联主席多明格斯25日与今年解放者杯决赛对阵的两支俱乐部负责人会晤,宣布决赛现场观众人数增加到球场容量的75%,即近4 5万人。今年

2021-10-27     
22年从警生涯 面对荣誉他说不要给我报功

9月24日,时任安徽省安庆市公安局迎江分局刑警大队大要案中队中队长周磊因在工作中激烈搏斗引发心源性猝死,倒在了工作岗位上,经医院抢救

2021-10-27