python在協(xié)程中增加任務(wù)

1、添加一個(gè)任務(wù)

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

asynicio.run(task2)

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

importasyncio

importtime

asyncdefvisit_url(url,response_time):

"""訪問url"""

awaitasyncio.sleep(response_time)

returnf"訪問{url},已得到返回結(jié)果"

asyncdefrun_task():

"""收集子任務(wù)"""

task=visit_url('http://wangzhen.com',2)

task_2=visit_url('http://another',3)

awaitasyncio.run(task)

awaitasyncio.run(task_2)

asyncio.run(run_task())

print(f"消耗時(shí)間：{time.perf_counter()-start_time}")

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

asyncdefrun_task():

"""收集子任務(wù)"""

task=visit_url('http://wangzhen.com',2)

task_2=visit_url('http://another',3)

awaitasynicio.gather(task1,task2)

以上就是python在協(xié)程中增加任務(wù)的方法，希望能對(duì)大家有所幫助。更多Python學(xué)習(xí)教程請(qǐng)關(guān)注IT培訓(xùn)機(jī)構(gòu):千鋒教育。