溫馨提示×

溫馨提示×

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

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

使用python怎么在協(xié)程中增加任務

發(fā)布時間:2021-04-27 16:46:32 來源:億速云 閱讀:191 作者:Leah 欄目:編程語言

使用python怎么在協(xié)程中增加任務?相信很多沒有經(jīng)驗的人對此束手無策,為此本文總結了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。

python主要應用領域有哪些

1、云計算,典型應用OpenStack。2、WEB前端開發(fā),眾多大型網(wǎng)站均為Python開發(fā)。3.人工智能應用,基于大數(shù)據(jù)分析和深度學習而發(fā)展出來的人工智能本質(zhì)上已經(jīng)無法離開python。4、系統(tǒng)運維工程項目,自動化運維的標配就是python+Django/flask。5、金融理財分析,量化交易,金融分析。6、大數(shù)據(jù)分析。

1、添加一個任務

task2 = visit_url('http://another.com', 3)
asynicio.run(task2)

2、這 2 個程序一共消耗 5s 左右的時間。并沒有發(fā)揮并發(fā)編程的優(yōu)勢

import asyncio
import time
 
async def visit_url(url, response_time):
    """訪問 url"""
    await asyncio.sleep(response_time)
    return f"訪問{url}, 已得到返回結果"
 
async def run_task():
    """收集子任務"""
    task = visit_url('http://wangzhen.com', 2)
    task_2 = visit_url('http://another', 3)
    await asyncio.run(task)
    await asyncio.run(task_2)
 
asyncio.run(run_task())
print(f"消耗時間:{time.perf_counter() - start_time}")

3、如果是并發(fā)編程,這個程序只需要消耗 3s,也就是task2的等待時間。要想使用并發(fā)編程形式,需要把上面的代碼改一下。asyncio.gather 會創(chuàng)建 2 個子任務,當出現(xiàn) await 的時候,程序會在這 2 個子任務之間進行調(diào)度。

async def run_task():
    """收集子任務"""
    task = visit_url('http://wangzhen.com', 2)
    task_2 = visit_url('http://another', 3)
    await asynicio.gather(task1, task2)

看完上述內(nèi)容,你們掌握使用python怎么在協(xié)程中增加任務的方法了嗎?如果還想學到更多技能或想了解更多相關內(nèi)容,歡迎關注億速云行業(yè)資訊頻道,感謝各位的閱讀!

向AI問一下細節(jié)

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

AI