欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Python中g(shù)event模塊協(xié)程使用

 更新時(shí)間:2021年07月07日 16:11:54   作者:Python測(cè)試開發(fā)  
協(xié)程是一種用戶態(tài)的輕量級(jí)線程,本文主要介紹了Python中g(shù)event模塊協(xié)程使用,文中通過示例代碼介紹的非常詳細(xì),需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

背景

因?yàn)?Python 線程的性能問題,在 Python 中使用多線程運(yùn)行代碼經(jīng)常不能達(dá)到預(yù)期的效果。而實(shí)際開發(fā)中我們經(jīng)常有高并發(fā)的需求,這就要求我們的代碼在跑的更快的同時(shí)需要單位時(shí)間內(nèi)執(zhí)行更多的有效邏輯、減少無用的等待。

什么是協(xié)程?

我們可以認(rèn)為線程是輕量級(jí)的進(jìn)程,所以你也可以理解協(xié)程是輕量級(jí)的線程。協(xié)程即在一個(gè)線程執(zhí)行 A 函數(shù)時(shí)可以隨時(shí)中斷去執(zhí)行 B 函數(shù),可以自由切換。但這個(gè)過程并不是函數(shù)調(diào)用,現(xiàn)象和多線程一樣,實(shí)際上是一個(gè)線程。其中 gevent 是 Python 協(xié)程的一個(gè)經(jīng)典實(shí)現(xiàn)。

什么是 gevent?

gevent 是 Python 的一個(gè)并發(fā)框架,基于 greenlet 實(shí)現(xiàn),使用了 epoll 事件監(jiān)聽機(jī)制以及諸多其他優(yōu)化而變得高效。其基本思想就是一個(gè) greenlet 就是一個(gè)協(xié)程,當(dāng) greenlet 遇到 IO 操作時(shí),比如訪問網(wǎng)絡(luò),就會(huì)自動(dòng)切換到其他的 greenlet,等待 IO 完成再切換回來繼續(xù)執(zhí)行。gevent 可以幫我們自動(dòng)實(shí)現(xiàn)這個(gè)協(xié)程切換的過程。

協(xié)程的例子

代碼:

import gevent,time

def f1():
    for i in range(5):
        print('function:@@@f1 | NUM: @@@',i)

        # 此處阻塞,gevent會(huì)幫我們切換到其他協(xié)程去↓
        gevent.sleep(0)

def f2():
    for i in range(5):
        print('function:@@@f2 | NUM: @@@',i)

        # 此處阻塞,gevent會(huì)幫我們切換到其他協(xié)程去↑
        gevent.sleep(0)

# 創(chuàng)建兩個(gè)協(xié)程對(duì)象,分別去執(zhí)行兩個(gè)函數(shù)
xc1=gevent.spawn(f1)
xc2=gevent.spawn(f2)

# 將協(xié)程們交給gevent去執(zhí)行
gevent.joinall([xc1,xc2])

執(zhí)行結(jié)果:

function:@@@f1 | NUM: @@@ 0
function:@@@f2 | NUM: @@@ 0
function:@@@f1 | NUM: @@@ 1
function:@@@f2 | NUM: @@@ 1
function:@@@f1 | NUM: @@@ 2
function:@@@f2 | NUM: @@@ 2
function:@@@f1 | NUM: @@@ 3
function:@@@f2 | NUM: @@@ 3
function:@@@f1 | NUM: @@@ 4
function:@@@f2 | NUM: @@@ 4

如上,當(dāng) gevent 幫我們執(zhí)行兩個(gè)協(xié)程的時(shí)候,首先 xc1 執(zhí)行到 gevent.sleep(0)時(shí)發(fā)生阻塞,此時(shí),gevent 幫我們將切換到xc2,xc2 執(zhí)行到 gevent.sleep(0)時(shí)又發(fā)生了阻塞,此時(shí),gevent 又幫我們將切換到 xc1 去執(zhí)行。

Q&A

Q:gevent 無法捕獲的耗時(shí)

代碼:

import gevent,time

def f1():
    for i in range(5):
        print('function:@@@f1 | NUM: @@@',i)

        # 注意這里
        time.sleep(0.1)

def f2():
    for i in range(5):
        print('function:@@@f2 | NUM: @@@',i)

        # 注意這里
        time.sleep(0.1)

# 創(chuàng)建兩個(gè)協(xié)程對(duì)象,分別去執(zhí)行兩個(gè)函數(shù)
xc1=gevent.spawn(f1)
xc2=gevent.spawn(f2)

# 將協(xié)程們交給gevent去執(zhí)行
gevent.joinall([xc1,xc2])

執(zhí)行結(jié)果:

function:@@@f1 | NUM: @@@ 0
function:@@@f1 | NUM: @@@ 1
function:@@@f1 | NUM: @@@ 2
function:@@@f1 | NUM: @@@ 3
function:@@@f1 | NUM: @@@ 4
function:@@@f2 | NUM: @@@ 0
function:@@@f2 | NUM: @@@ 1
function:@@@f2 | NUM: @@@ 2
function:@@@f2 | NUM: @@@ 3
function:@@@f2 | NUM: @@@ 4

如上,你會(huì)發(fā)現(xiàn),time.sleep(0.1)耗費(fèi)的時(shí)間,gevent 無法捕捉,導(dǎo)致代碼是串行的,雖然我們創(chuàng)建了協(xié)程,但是并沒有起到異步的作用。
怎么辦呢?請(qǐng)看下面的解決方案。

A:猴子補(bǔ)丁

對(duì)于無法捕獲的耗時(shí),gevent 為我們提供了猴子補(bǔ)丁,當(dāng)我們?yōu)槲覀兊某绦虼蛄撕镒友a(bǔ)丁,那么當(dāng)我們的程序遇到任何耗時(shí)的操作,gevent 都會(huì)幫我們?nèi)プ詣?dòng)切換協(xié)程,從而實(shí)現(xiàn)異步高并發(fā)。

代碼:

import gevent,time
from gevent import monkey;monkey.patch_all()

def f1():
    for i in range(5):
        print('function:@@@f1 | NUM: @@@',i)

        # 注意這里
        time.sleep(0.1)

def f2():
    for i in range(5):
        print('function:@@@f2 | NUM: @@@',i)

        # 注意這里
        time.sleep(0.1)

# 創(chuàng)建兩個(gè)協(xié)程對(duì)象,分別去執(zhí)行兩個(gè)函數(shù)
xc1=gevent.spawn(f1)
xc2=gevent.spawn(f2)

# 將協(xié)程們交給gevent去執(zhí)行
gevent.joinall([xc1,xc2])

執(zhí)行結(jié)果:

function:@@@f1 | NUM: @@@ 0
function:@@@f2 | NUM: @@@ 0
function:@@@f1 | NUM: @@@ 1
function:@@@f2 | NUM: @@@ 1
function:@@@f1 | NUM: @@@ 2
function:@@@f2 | NUM: @@@ 2
function:@@@f1 | NUM: @@@ 3
function:@@@f2 | NUM: @@@ 3
function:@@@f1 | NUM: @@@ 4
function:@@@f2 | NUM: @@@ 4

如上,你會(huì)發(fā)現(xiàn)協(xié)程的切換已經(jīng)實(shí)現(xiàn),問題完美解決。

實(shí)踐

異步 requests 請(qǐng)求

代碼:

from gevent import monkey;monkey.patch_all()
import gevent,time,requests
from urllib3 import disable_warnings

disable_warnings()

def req(url):
    res = requests.get(url,verify=False)
    if res:
        print('URL:{} | CODE:{}!'.format(url,res.status_code))
    else:
        print('URL:{} FAILED!')

xc1=gevent.spawn(req,'https://www.baidu.com')
xc2=gevent.spawn(req,'https://www.gitee.com')
xc3=gevent.spawn(req,'https://www.huaweicloud.com')

gevent.joinall([xc1,xc2,xc3])

執(zhí)行結(jié)果:

URL:https://www.baidu.com | CODE:200!
URL:https://www.huaweicloud.com | CODE:200!
URL:https://www.gitee.com | CODE:200!

gevent 的鎖

代碼:

from gevent import monkey;monkey.patch_all()
from gevent.lock import Semaphore
import gevent,time

# 信號(hào)量設(shè)置為1
s1=Semaphore(1)

def f1():
    for i in range(5):
        # 信號(hào)量-1,即拿到鎖
        s1.acquire()
        print('function:@@@f1 | NUM: @@@',i)

        # 信號(hào)量+1,即釋放鎖
        s1.release()

        # 猴子補(bǔ)丁幫忙識(shí)別阻塞
        time.sleep(0.1)

def f2():
    for i in range(5):
        # 信號(hào)量-1,即拿到鎖
        s1.acquire()
        print('function:@@@f2 | NUM: @@@',i)

        # 信號(hào)量+1,即釋放鎖
        s1.release()

        # 猴子補(bǔ)丁幫忙識(shí)別阻塞
        time.sleep(0.3)

# 創(chuàng)建兩個(gè)協(xié)程對(duì)象,分別去執(zhí)行兩個(gè)函數(shù)
xc1=gevent.spawn(f1)
xc2=gevent.spawn(f2)

# 將協(xié)程們交給gevent去執(zhí)行
gevent.joinall([xc1,xc2])

執(zhí)行結(jié)果:

function:@@@f1 | NUM: @@@ 0
function:@@@f2 | NUM: @@@ 0
function:@@@f1 | NUM: @@@ 1
function:@@@f1 | NUM: @@@ 2
function:@@@f2 | NUM: @@@ 1
function:@@@f1 | NUM: @@@ 3
function:@@@f1 | NUM: @@@ 4
function:@@@f2 | NUM: @@@ 2
function:@@@f2 | NUM: @@@ 3
function:@@@f2 | NUM: @@@ 4

如上,可以看到,gevent 可以自動(dòng)處理鎖和阻塞。按阻塞規(guī)律,f1 和 f2 會(huì)交替執(zhí)行,但是加上阻塞時(shí)間,因?yàn)?f2 的阻塞時(shí)間是 f1 的 3 倍,所以前 6 條打印中,f1 執(zhí)行的次數(shù)是 f2 的三倍,即 gevent 可以自動(dòng)判斷和處理阻塞和鎖同時(shí)存在的情況。

Tip

在 HTTP 的異步開發(fā)中,猴子補(bǔ)丁要在導(dǎo)入 gevent 之前打,否則會(huì)出現(xiàn)異常。

到此這篇關(guān)于Python中g(shù)event模塊協(xié)程使用的文章就介紹到這了,更多相關(guān)Python gevent協(xié)程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Python實(shí)現(xiàn)動(dòng)態(tài)柱狀圖的繪制

    Python實(shí)現(xiàn)動(dòng)態(tài)柱狀圖的繪制

    這篇文章主要為大家詳細(xì)介紹了Python實(shí)現(xiàn)動(dòng)態(tài)柱狀圖的繪制的相關(guān)資料,文中的示例代碼講解詳細(xì),具有一定的學(xué)習(xí)與借鑒價(jià)值,需要的可以參考一下
    2022-12-12
  • pandas中Series運(yùn)算匯總(算術(shù)、比較和邏輯運(yùn)算)

    pandas中Series運(yùn)算匯總(算術(shù)、比較和邏輯運(yùn)算)

    本文主要介紹了pandas中Series運(yùn)算匯總,包括算術(shù)運(yùn)算、比較運(yùn)算和邏輯運(yùn)算等,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2024-06-06
  • Python垃圾回收及Linux?Fork

    Python垃圾回收及Linux?Fork

    這篇文章主要介紹了Python垃圾回收及Linux?Forkm,Python垃圾回收主要以引用計(jì)數(shù)為主,分代回收為輔,而一個(gè)進(jìn)程調(diào)用fork()函數(shù)后,系統(tǒng)先給新的進(jìn)程分配資源,例如存儲(chǔ)數(shù)據(jù)和代碼的空間,下面來看文章具體介紹吧
    2022-01-01
  • python logging.basicConfig不生效的原因及解決

    python logging.basicConfig不生效的原因及解決

    今天小編就為大家分享一篇python logging.basicConfig不生效的原因及解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
    2020-02-02
  • Python控制臺(tái)獲取輸入與常見的正則表達(dá)式用法

    Python控制臺(tái)獲取輸入與常見的正則表達(dá)式用法

    這篇文章主要給大家介紹了關(guān)于Python控制臺(tái)獲取輸入與常見的正則表達(dá)式用法的相關(guān)資料,在Python編程中,控制臺(tái)輸入和正則表達(dá)式是兩個(gè)重要而實(shí)用的概念,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2023-12-12
  • python+openCV調(diào)用攝像頭拍攝和處理圖片的實(shí)現(xiàn)

    python+openCV調(diào)用攝像頭拍攝和處理圖片的實(shí)現(xiàn)

    這篇文章主要介紹了python+openCV調(diào)用攝像頭拍攝和處理圖片的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-08-08
  • Cython編譯python為so 代碼加密示例

    Cython編譯python為so 代碼加密示例

    今天小編就為大家分享一篇Cython編譯python為so 代碼加密示例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
    2019-12-12
  • Python WXPY實(shí)現(xiàn)微信監(jiān)控報(bào)警功能的代碼

    Python WXPY實(shí)現(xiàn)微信監(jiān)控報(bào)警功能的代碼

    本篇文章主要介紹了Python WXPY實(shí)現(xiàn)微信監(jiān)控報(bào)警功能的代碼,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2017-10-10
  • 解決Python列表字符不區(qū)分大小寫的問題

    解決Python列表字符不區(qū)分大小寫的問題

    今天小編就為大家分享一篇解決Python列表字符不區(qū)分大小寫的問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
    2019-12-12
  • Python實(shí)現(xiàn)3行代碼解簡(jiǎn)單的一元一次方程

    Python實(shí)現(xiàn)3行代碼解簡(jiǎn)單的一元一次方程

    這篇文章主要介紹了Python實(shí)現(xiàn)3行代碼解簡(jiǎn)單的一元一次方程,很適合Python初學(xué)者學(xué)習(xí)借鑒,需要的朋友可以參考下
    2014-08-08

最新評(píng)論