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

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

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

import asyncioimport timeasync 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'消耗時(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)度。

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 asynciofrom threading import Thread async def production_task(): i = 0 while True: # 將consumption這個(gè)協(xié)程每秒注冊一個(gè)到運(yùn)行在線程中的循環(huán)，thread_loop每秒會(huì)獲得一個(gè)一直打印i的無限循環(huán)任務(wù) asyncio.run_coroutine_threadsafe(consumption(i), thread_loop) # 注意：run_coroutine_threadsafe 這個(gè)方法只能用在運(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() # 獲取一個(gè)事件循環(huán)run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 將次事件循環(huán)運(yùn)行在一個(gè)線程中，防止阻塞當(dāng)前主線程run_loop_thread.start() # 運(yùn)行線程，同時(shí)協(xié)程事件循環(huán)也會(huì)運(yùn)行 advocate_loop = asyncio.get_event_loop() # 將生產(chǎn)任務(wù)的協(xié)程注冊到這個(gè)循環(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)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！