主頁(yè) > 知識(shí)庫(kù) > python在協(xié)程中增加任務(wù)實(shí)例操作

python在協(xié)程中增加任務(wù)實(shí)例操作

熱門標(biāo)簽:舉辦過冬奧會(huì)的城市地圖標(biāo)注 400電話申請(qǐng)資格 正安縣地圖標(biāo)注app 阿里電話機(jī)器人對(duì)話 電銷機(jī)器人系統(tǒng)廠家鄭州 地圖地圖標(biāo)注有嘆號(hào) 螳螂科技外呼系統(tǒng)怎么用 遼寧智能外呼系統(tǒng)需要多少錢 qt百度地圖標(biāo)注

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

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

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

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"消耗時(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 asyncio
from threading import Thread
 
 
async def production_task():
  i = 0
  while True:
    # 將consumption這個(gè)協(xié)程每秒注冊(cè)一個(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é)程注冊(cè)到這個(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)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

您可能感興趣的文章:
  • 深入理解python協(xié)程
  • 詳解Python生成器和基于生成器的協(xié)程
  • python 如何引入?yún)f(xié)程和原理分析
  • python3爬蟲中異步協(xié)程的用法
  • Python協(xié)程的方式實(shí)現(xiàn)及意義筆記分享

標(biāo)簽:淘寶好評(píng)回訪 濟(jì)源 興安盟 隨州 合肥 阜新 信陽(yáng) 昭通

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《python在協(xié)程中增加任務(wù)實(shí)例操作》,本文關(guān)鍵詞  python,在,協(xié)程,中,增加,任務(wù),;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《python在協(xié)程中增加任務(wù)實(shí)例操作》相關(guān)的同類信息!
  • 本頁(yè)收集關(guān)于python在協(xié)程中增加任務(wù)實(shí)例操作的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章