建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
如何使用python的Task封裝協(xié)程
本文小編為大家詳細介紹“如何使用python的Task封裝協(xié)程”，內(nèi)容詳細，步驟清晰，細節(jié)處理妥當，希望這篇“如何使用python的Task封裝協(xié)程”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。
網(wǎng)站建設哪家好，找創(chuàng)新互聯(lián)！專注于網(wǎng)頁設計、網(wǎng)站建設、微信開發(fā)、微信小程序開發(fā)、集團企業(yè)網(wǎng)站建設等服務項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了河東免費建站歡迎大家使用！
說明
1、Task是Future的子類，Task是對協(xié)程的封裝，我們把多個Task放在循環(huán)調(diào)度列表中，等待調(diào)度執(zhí)行。
2、Task對象可以跟蹤任務和狀態(tài)。Future(Task是Futrue的子類)為我們提供了異步編程中最終結果的處理(Task類還具有狀態(tài)處理功能)。
3、把協(xié)程封裝成Task，加入一個隊列等待調(diào)用。剛創(chuàng)建Task的時候不執(zhí)行，遇到await就執(zhí)行。
實例
import asyncio
async def func():
print(1)
await asyncio.sleep(2)
print(2)
return "返回值"
async def main():
print("main開始")
# 創(chuàng)建協(xié)程，將協(xié)程封裝到Task對象中并添加到事件循環(huán)的任務列表中，等待事件循環(huán)去執(zhí)行（默認是就緒狀態(tài)）。
# 在調(diào)用
task_list = [
asyncio.create_task(func(), name="n1"),
asyncio.create_task(func(), name="n2")
]
print("main結束")
# 當執(zhí)行某協(xié)程遇到IO操作時，會自動化切換執(zhí)行其他任務。
# 此處的await是等待所有協(xié)程執(zhí)行完畢，并將所有協(xié)程的返回值保存到done
# 如果設置了timeout值，則意味著此處最多等待的秒，完成的協(xié)程返回值寫入到done中，未完成則寫到pending中。
done, pending = await asyncio.wait(task_list, timeout=None)
print(done, pending)
asyncio.run(main())讀到這里，這篇“如何使用python的Task封裝協(xié)程”文章已經(jīng)介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內(nèi)容的文章，歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
當前題目：如何使用python的Task封裝協(xié)程
鏈接URL：http://fisionsoft.com.cn/article/pcpcjs.html
