溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

asyncio異步編程中Task對(duì)象是什么

發(fā)布時(shí)間:2022-03-14 09:21:50 來(lái)源:億速云 閱讀:152 作者:小新 欄目:開發(fā)技術(shù)

小編給大家分享一下asyncio異步編程中Task對(duì)象是什么,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

1.Task對(duì)象的作用

可以將多個(gè)任務(wù)添加到事件循環(huán)當(dāng)中,達(dá)到多任務(wù)并發(fā)的效果

2.如何創(chuàng)建task對(duì)象

asyncio.create_task(協(xié)程對(duì)象)

注意create_task只有在python3.7及以后的版本中才可以使用,就像asyncio.run()一樣,

在3.7以前可以使用asyncio.ensure_future()方式創(chuàng)建task對(duì)象

3.示例一(目前不推薦這種寫法)

async def func():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return "test"
async def main():
    print("main start")
    # python 3.7及以上版本的寫法
    # task1 = asyncio.create_task(func())
    # task2 = asyncio.create_task(func())
    # python3.7以前的寫法
    task1 = asyncio.ensure_future(func())
    task2 = asyncio.ensure_future(func())
    print("main end")
    ret1 = await task1
    ret2 = await task2
    print(ret1, ret2)
# python3.7以后的寫法
# asyncio.run(main())
# python3.7以前的寫法
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
"""
在創(chuàng)建task的時(shí)候,就將創(chuàng)建好的task添加到了時(shí)間循環(huán)當(dāng)中,所以說(shuō)必須得有時(shí)間循環(huán),才可以創(chuàng)建task,否則會(huì)報(bào)錯(cuò)
"""

4.示例2

async def func1():
    print(1111)
    await asyncio.sleep(2)
    print(2222)
    return "test"
async def main1():
    print("main start")
    tasks = [
        asyncio.ensure_future(func1()),
        asyncio.ensure_future(func1())
    ]
    print("main end")
    # 執(zhí)行成功后結(jié)果在done中, wait中可以加第二個(gè)參數(shù)timeout,如果在超時(shí)時(shí)間內(nèi)沒(méi)有完成,那么pending就是未執(zhí)行完的東西
    done, pending = await asyncio.wait(tasks, timeout=1)
    print(done)
    #print(pending)
# python3.7以前的寫法
loop = asyncio.get_event_loop()
loop.run_until_complete(main1())

5.示例3(算是以上示例2的簡(jiǎn)化版)

"""
方式二的簡(jiǎn)化版,就是tasks中不直接添加task,而是先將協(xié)程對(duì)象加入到list中,在最后運(yùn)行中添加
"""
async def func2():
    print(1111)
    await asyncio.sleep(2)
    print(2222)
    return "test"
tasks = [
    func2(),
    func2()
]
# python3.7以前的寫法
loop = asyncio.get_event_loop()
done, pending = loop.run_until_complete(asyncio.wait(tasks))
print(done)
print(pending)

以上是“asyncio異步編程中Task對(duì)象是什么”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對(duì)大家有所幫助,如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI