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

1、添加一個任務

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

asynicio.run(task2)

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

importasyncio

importtime

asyncdefvisit_url(url,response_time):

"""訪問url"""

awaitasyncio.sleep(response_time)

returnf"訪問{url},已得到返回結果"

asyncdefrun_task():

"""收集子任務"""

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"消耗時間：{time.perf_counter()-start_time}")

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

asyncdefrun_task():

"""收集子任務"""

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

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

awaitasynicio.gather(task1,task2)

以上就是python在協(xié)程中增加任務的方法，希望能對大家有所幫助。更多Python學習教程請關注IT培訓機構:千鋒教育。