Python筆記(十八):協程asyncio

来源:https://www.cnblogs.com/simple-free/archive/2020/06/06/13053168.html
-Advertisement-
Play Games

(一)asyncio 1、asyncio 用async 修飾詞來聲明非同步函數 2、asyncio.create_task(非同步函數)來創建任務 3、通過await asyncio.gather(任務)來執行任務 4、通過asyncio.run(函數)來觸發運行 5、一個比較好的方式是asyncio. ...


(一)asyncio

1、asyncio 用async 修飾詞來聲明非同步函數

2、asyncio.create_task(非同步函數)來創建任務

3、通過await asyncio.gather(任務)來執行任務

4、通過asyncio.run(函數)來觸發運行

5、一個比較好的方式是asyncio.run(main())作為程式入口,在程式運行周期內,只調用一次asyncio.run()

例如:請求5次這個url https://www.java.com/zh_CN/

用協程是3.8s,不用協程9.2s。當然這個時間對比可能不是非常準確,因為請求過程還受其他因素影響,不過應該能大致說明問題。

 1 import datetime
 2 
 3 import asyncio
 4 import aiohttp
 5 
 6 header = {
 7     "User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.138 Safari/537.36",
 8     "Host":"c.oracleinfinity.io",
 9     "Accept-Encoding":"gzip, deflate, br",
10     "accept":"text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9"
11 }
12 async def fetch_content(url):
13     async with aiohttp.ClientSession(
14         headers=header,connector=aiohttp.TCPConnector(ssl=False)
15     ) as session:
16         async with session.get(url) as response:
17             return await response.text()
18 
19 async def main():
20     url = "https://www.java.com/zh_CN/"
21     urls = [url for i in range(5)]
22     tasks = [asyncio.create_task(fetch_content(url)) for url in urls]
23     pages = await asyncio.gather(*tasks)  #*表示解包列表,解包字典則用2個星號**
24 
25 
26 start_time = datetime.datetime.now()
27 print(start_time)
28 asyncio.run(main())
29 end_time = datetime.datetime.now()
30 print(end_time - start_time)

不用協程

import requests
import datetime

header = {
    "User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/81.0.4044.138 Safari/537.36",
    "Host":"c.oracleinfinity.io",
    "Accept-Encoding":"gzip, deflate, br",
    "accept":"text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9"
}

def main():
    url = "https://www.java.com/zh_CN/"
    for i in range(5):
        page = requests.get(url,headers=header).content


start_time = datetime.datetime.now()
print(start_time)
main()
end_time = datetime.datetime.now()
print(end_time - start_time)

 

 

 

對協程的理解:

例如:小明是一個客服,現在有5個用戶同時像他咨詢問題。(可以抽象為5個任務)

普通的處理方式是:

1、先完全解決用戶1的疑問。(完成任務1)

2、直到用戶1回覆說沒疑問了,再去解決用戶2的疑問(完成任務2)

。。。。重覆這個過程,直到解決完5個用戶的疑問。

協程的處理方式是:

1、回覆用戶1 。

2、等待用戶1回覆的過程中,去回覆用戶2

3、等待用戶2回覆的過程中,去回覆用戶3.

4、用戶1回覆了,繼續回覆用戶1

.......重覆這個過程,直到解答完5個用戶的疑問。

總之,

1、普通的處理方式就是5個任務依次執行,直到執行完成所有任務。

2、而協程的處理方式是。

    (1)任務遇到阻塞(需要等待)的地方時,調度器會去執行其他任務

    (2)當需要等待的部分處理完成後,會告訴調度器,我執行完了。然後調度器會繼續執行這個任務後續的部分。

    (3)重覆(1)、(2)過程,直到所有任務處理完畢。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • ##1.1 前言 很久之前在做一個網站的時候,發現的一個問題。 之前在搭建完網站需要啟動Mysql的時候,死活啟動不了。為什麼?我查了下日誌,發現是etc/mysql/下的Mysql配置文件一直無法生成。 這個文件一般是隨著Mysql服務重啟的時候會自動生成到etc/配置文件下。我當前的機器記憶體是很 ...
  • linux文件系統: 文件系統常用的Linux分為EXT1,EXT2,EXT3,EXT4,xfs,vfat等 windows:NTFS,fat12,fat16等 linux分區: linux文件分區工具有: fdisk 主要為msdos(MBR)分區表支持 最多只可以分出4個主分區或者3個主分區(p ...
  • 巨杉資料庫榮譽入選中國企業服務競爭力榜單,技術產品方向和企業級市場領先地位再獲認可。 ...
  • 一、向集合添加一個或多個成員 命令:sadd 格式:sadd key member1 [member2] 127.0.0.1:6379> sadd set_key m1 (integer) 1 127.0.0.1:6379> sadd set_key m2 m3 (integer) 2 二、返回集合 ...
  • 安裝pg10 一、install yum install https://download.postgresql.org/pub/repos/yum/reporpms/EL-7-x86_64/pgdg-redhat-repo-latest.noarch.rpm yum install postgre ...
  • -- 創建用戶 create user '用戶名'@'ip地址' identified by 'password'; ip adress 可填%,即指可以在任何電腦上登錄 -- 給用戶進行授權 (一)grant 許可權(select,insert,update) on 資料庫名.表名 to '用戶名' ...
  • 本文記錄,將常用的 Python 腳本,放到任務欄,的設置方法。 把 Python 腳本,放到任務欄,的方法如下: 首先,要創建一個當前 Python 腳本文件的快捷方式。 然後,滑鼠右鍵,點擊腳本文件,打開文件屬性界面。 然後,手動更改快捷鍵的路徑(Target);把快捷方式的,路徑格式,改為如下 ...
  • 安裝前準備: 安裝之前事先安裝好elasticsearch和kibana。 下載安裝包: apm-server-7.0.0-linux-x86_64.tar.gz (服務端包)elastic-apm-agent-1.7.0.jar(終端包) 安裝步驟: Apm-server終端安裝 Apm-serv ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...