1、添加一個任務(wù)
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}, 已得到返回結(jié)果"
async def run_task():
"""收集子任務(wù)"""
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 個子任務(wù)，當(dāng)出現(xiàn) await 的時候，程序會在這 2 個子任務(wù)之間進(jìn)行調(diào)度。
async def run_task():
"""收集子任務(wù)"""
task = visit_url('http://wangzhen.com', 2)
task_2 = visit_url('http://another', 3)
await asynicio.gather(task1, task2)
實(shí)例擴(kuò)展：
import asyncio
from threading import Thread
async def production_task():
i = 0
while True:
# 將consumption這個協(xié)程每秒注冊一個到運(yùn)行在線程中的循環(huán)，thread_loop每秒會獲得一個一直打印i的無限循環(huán)任務(wù)
asyncio.run_coroutine_threadsafe(consumption(i),
thread_loop) # 注意：run_coroutine_threadsafe 這個方法只能用在運(yùn)行在線程中的循環(huán)事件使用
await asyncio.sleep(1) # 必須加await
i += 1
async def consumption(i):
while True:
print("我是第{}任務(wù)".format(i))
await asyncio.sleep(1)
def start_loop(loop):
# 運(yùn)行事件循環(huán)， loop以參數(shù)的形式傳遞進(jìn)來運(yùn)行
asyncio.set_event_loop(loop)
loop.run_forever()
thread_loop = asyncio.new_event_loop() # 獲取一個事件循環(huán)
run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 將次事件循環(huán)運(yùn)行在一個線程中，防止阻塞當(dāng)前主線程
run_loop_thread.start() # 運(yùn)行線程，同時協(xié)程事件循環(huán)也會運(yùn)行
advocate_loop = asyncio.get_event_loop() # 將生產(chǎn)任務(wù)的協(xié)程注冊到這個循環(huán)中
advocate_loop.run_until_complete(production_task()) # 運(yùn)行次循環(huán)
到此這篇關(guān)于python在協(xié)程中增加任務(wù)實(shí)例操作的文章就介紹到這了,更多相關(guān)python在協(xié)程中增加任務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- 深入理解python協(xié)程
- 詳解Python生成器和基于生成器的協(xié)程
- python 如何引入?yún)f(xié)程和原理分析
- python3爬蟲中異步協(xié)程的用法
- Python協(xié)程的方式實(shí)現(xiàn)及意義筆記分享
