99999久久久久久亚洲,欧美人与禽猛交狂配,高清日韩av在线影院,一个人在线高清免费观看,啦啦啦在线视频免费观看www

熱線電話：13121318867

登錄
首頁精彩閱讀學(xué)了協(xié)程之后，感覺有了無數(shù)個(gè)分身
學(xué)了協(xié)程之后，感覺有了無數(shù)個(gè)分身
2022-08-05
收藏

作者：小K

來源：麥?zhǔn)寰幊?/span>

?

上次的關(guān)于進(jìn)程、線程和協(xié)程的文章，很多粉絲留言表示想看協(xié)程的實(shí)際案例。

?

?

那么今天就來結(jié)合代碼實(shí)際講一個(gè)協(xié)程的實(shí)際應(yīng)用。

在此之前，我希望大家能已經(jīng)理解什么是串行、并行和并發(fā)的概念。如果你還不知道這三者的區(qū)別請前往Python三分鐘第131篇復(fù)習(xí)學(xué)習(xí)。

?

普通函數(shù)

定義一個(gè)洗衣服函數(shù)，洗衣服過程時(shí)間為2秒。

睡眠 

import timedef wash_clothes(): time.sleep(2) # 洗衣服def run(): for i in range(20):  wash_clothes() print(f"衣服洗好了！當(dāng)前時(shí)間：{time.time()}") if __name__ == '__main__': run()

運(yùn)行結(jié)果： 

衣服洗好了！當(dāng)前時(shí)間：1659618457.003896衣服洗好了！當(dāng)前時(shí)間：1659618459.005437衣服洗好了！當(dāng)前時(shí)間：1659618461.0056782衣服洗好了！當(dāng)前時(shí)間：1659618463.010311衣服洗好了！當(dāng)前時(shí)間：1659618465.013951衣服洗好了！當(dāng)前時(shí)間：1659618467.018253衣服洗好了！當(dāng)前時(shí)間：1659618469.022136衣服洗好了！當(dāng)前時(shí)間：1659618471.022881衣服洗好了！當(dāng)前時(shí)間：1659618473.023118衣服洗好了！當(dāng)前時(shí)間：1659618475.027102衣服洗好了！當(dāng)前時(shí)間：1659618477.030786衣服洗好了！當(dāng)前時(shí)間：1659618479.032495衣服洗好了！當(dāng)前時(shí)間：1659618481.037195衣服洗好了！當(dāng)前時(shí)間：1659618483.040722衣服洗好了！當(dāng)前時(shí)間：1659618485.041149衣服洗好了！當(dāng)前時(shí)間：1659618487.046405衣服洗好了！當(dāng)前時(shí)間：1659618489.0484421衣服洗好了！當(dāng)前時(shí)間：1659618491.050224衣服洗好了！當(dāng)前時(shí)間：1659618493.055479衣服洗好了！當(dāng)前時(shí)間：1659618495.0585659

我們可以看出，函數(shù)間隔2秒多一點(diǎn)點(diǎn)輸出一次時(shí)間。

協(xié)程函數(shù)

注意代碼中注釋 

import timeimport asyncio# 異步函數(shù)定義需要在def前加async前綴async def wash_clothes():  # sleep也需要使用協(xié)程專用的模塊支持，同步的庫不能在異步中使用 asyncio.sleep(2) print(f"衣服洗好了！當(dāng)前時(shí)間：{time.time()}")def run(): for i in range(20):    # 將協(xié)程函數(shù)注冊到loop（循環(huán)事件）中 loop.run_until_complete(wash_clothes())# 創(chuàng)建一個(gè)協(xié)程loop（循環(huán)事件）中loop = asyncio.get_event_loop()if __name__ =='__main__': run()

運(yùn)行結(jié)果： 

衣服洗好了！當(dāng)前時(shí)間：1659619085.0939178衣服洗好了！當(dāng)前時(shí)間：1659619085.094379衣服洗好了！當(dāng)前時(shí)間：1659619085.095523衣服洗好了！當(dāng)前時(shí)間：1659619085.095926衣服洗好了！當(dāng)前時(shí)間：1659619085.097046衣服洗好了！當(dāng)前時(shí)間：1659619085.0985332衣服洗好了！當(dāng)前時(shí)間：1659619085.099058衣服洗好了！當(dāng)前時(shí)間：1659619085.099848衣服洗好了！當(dāng)前時(shí)間：1659619085.101115衣服洗好了！當(dāng)前時(shí)間：1659619085.101917衣服洗好了！當(dāng)前時(shí)間：1659619085.1026182衣服洗好了！當(dāng)前時(shí)間：1659619085.103351衣服洗好了！當(dāng)前時(shí)間：1659619085.1034582衣服洗好了！當(dāng)前時(shí)間：1659619085.1035311衣服洗好了！當(dāng)前時(shí)間：1659619085.1042402衣服洗好了！當(dāng)前時(shí)間：1659619085.1052392衣服洗好了！當(dāng)前時(shí)間：1659619085.106337衣服洗好了！當(dāng)前時(shí)間：1659619085.106577衣服洗好了！當(dāng)前時(shí)間：1659619085.107519衣服洗好了！當(dāng)前時(shí)間：1659619085.108191

從運(yùn)行結(jié)果看出，20桶衣服幾乎在同0.1秒內(nèi)洗完了。

大致過程

  1. 定義協(xié)程函數(shù)；
  2. 創(chuàng)建協(xié)程循環(huán)事件；
  3. 將已定義的協(xié)程函數(shù)注冊到協(xié)程循環(huán)事件中；
  4. 啟動協(xié)程循環(huán)事件。

?

重點(diǎn)：協(xié)程函數(shù)內(nèi)不能使用同步的函數(shù)或模塊，否則將不會被異步運(yùn)行。

?

上一篇Python我提了協(xié)程執(zhí)行的過程就像，“一個(gè)人啟動一臺洗衣機(jī)后，馬上去使用第二臺洗衣機(jī)，再第三臺...第四臺...第十臺”。

「當(dāng)洗衣機(jī)啟動后的狀態(tài)就等于是掛起了」

然后協(xié)程馬上去啟動下一臺洗衣機(jī)...一直到結(jié)束。

后記

在某種意義上說，處理IO密集型任務(wù)協(xié)程的速度會高于多線程，因?yàn)榫€程的創(chuàng)建和銷毀需要消耗更多資源。

如果將這個(gè)大殺器用于網(wǎng)絡(luò)爬蟲，那不是速度要上天了？

是的，協(xié)程爬蟲超猛。以前親測比scrapy要快。

下期將從兩個(gè)話題中選出一個(gè)：

  1. 什么是IO密集型任務(wù)和計(jì)算密集型任務(wù)？
  2. 協(xié)程爬蟲
  3. 其他（寫上內(nèi)容）

數(shù)據(jù)分析咨詢請掃描二維碼

若不方便掃碼，搜微信號：CDAshujufenxi

數(shù)據(jù)分析師資訊
更多

OK
客服在線
立即咨詢
客服在線
立即咨詢
') } function initGt() { var handler = function (captchaObj) { captchaObj.appendTo('#captcha'); captchaObj.onReady(function () { $("#wait").hide(); }).onSuccess(function(){ $('.getcheckcode').removeClass('dis'); $('.getcheckcode').trigger('click'); }); window.captchaObj = captchaObj; }; $('#captcha').show(); $.ajax({ url: "/login/gtstart?t=" + (new Date()).getTime(), // 加隨機(jī)數(shù)防止緩存 type: "get", dataType: "json", success: function (data) { $('#text').hide(); $('#wait').show(); // 調(diào)用 initGeetest 進(jìn)行初始化 // 參數(shù)1：配置參數(shù) // 參數(shù)2：回調(diào)，回調(diào)的第一個(gè)參數(shù)驗(yàn)證碼對象，之后可以使用它調(diào)用相應(yīng)的接口 initGeetest({ // 以下 4 個(gè)配置參數(shù)為必須，不能缺少 gt: data.gt, challenge: data.challenge, offline: !data.success, // 表示用戶后臺檢測極驗(yàn)服務(wù)器是否宕機(jī) new_captcha: data.new_captcha, // 用于宕機(jī)時(shí)表示是新驗(yàn)證碼的宕機(jī) product: "float", // 產(chǎn)品形式，包括：float，popup width: "280px", https: true // 更多配置參數(shù)說明請參見：http://docs.geetest.com/install/client/web-front/ }, handler); } }); } function codeCutdown() { if(_wait == 0){ //倒計(jì)時(shí)完成 $(".getcheckcode").removeClass('dis').html("重新獲取"); }else{ $(".getcheckcode").addClass('dis').html("重新獲取("+_wait+"s)"); _wait--; setTimeout(function () { codeCutdown(); },1000); } } function inputValidate(ele,telInput) { var oInput = ele; var inputVal = oInput.val(); var oType = ele.attr('data-type'); var oEtag = $('#etag').val(); var oErr = oInput.closest('.form_box').next('.err_txt'); var empTxt = '請輸入'+oInput.attr('placeholder')+'！'; var errTxt = '請輸入正確的'+oInput.attr('placeholder')+'！'; var pattern; if(inputVal==""){ if(!telInput){ errFun(oErr,empTxt); } return false; }else { switch (oType){ case 'login_mobile': pattern = /^1[3456789]\d{9}$/; if(inputVal.length==11) { $.ajax({ url: '/login/checkmobile', type: "post", dataType: "json", data: { mobile: inputVal, etag: oEtag, page_ur: window.location.href, page_referer: document.referrer }, success: function (data) { } }); } break; case 'login_yzm': pattern = /^\d{6}$/; break; } if(oType=='login_mobile'){ } if(!!validateFun(pattern,inputVal)){ errFun(oErr,'') if(telInput){ $('.getcheckcode').removeClass('dis'); } }else { if(!telInput) { errFun(oErr, errTxt); }else { $('.getcheckcode').addClass('dis'); } return false; } } return true; } function errFun(obj,msg) { obj.html(msg); if(msg==''){ $('.login_submit').removeClass('dis'); }else { $('.login_submit').addClass('dis'); } } function validateFun(pat,val) { return pat.test(val); }