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

熱線電話:13121318867

登錄
首頁精彩閱讀我把多線程中的鎖刪了,領(lǐng)導(dǎo)還夸我機(jī)靈
我把多線程中的鎖刪了,領(lǐng)導(dǎo)還夸我機(jī)靈
2022-08-18
收藏

作者:小K

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

?

上期我給大家介紹了什么是線程安全線程非安全,今天帶大家深入了解下為什么會(huì)存在這兩種情況。

?

原子操作

大家還記得數(shù)據(jù)庫的事務(wù)正確執(zhí)行的四個(gè)基本要素ACID嗎?

因?yàn)锳CID的存在,數(shù)據(jù)庫的事務(wù)被執(zhí)行之后,要么全都完成(commit),要么全都不完成(rollback),不會(huì)存在部分完成,或錯(cuò)誤完成的情況。

其中,原子性(Atomicity)是保障這個(gè)特性重要的要素,就像原子不能被分割那樣。

在Python中,「原子操作(操作原子性)是保證線程安全最重要的因素。」

?

原子操作:一旦操作開始,就要一直運(yùn)行到結(jié)束,沒有任何線程調(diào)度機(jī)制能打斷它的操作。

?

如何判斷是否是原子操作

上一篇的例子中,我們通過運(yùn)行代碼可知zero += 1和zero -= 1是線程非安全操作。

那么有什么辦法在能不運(yùn)行代碼的階段去找到它呢?

「可以用dis模塊分析?!?/span>

from dis import diszero = 0def operation(): global zero    zero += 1 zero -= 1dis(operation)

運(yùn)行代碼:

28 0 LOAD_GLOBAL 0 (zero) 2 LOAD_CONST 1 (1) 4 INPLACE_ADD 6 STORE_GLOBAL 0 (zero) 29 8 LOAD_GLOBAL 0 (zero) 10 LOAD_CONST 1 (1) 12 INPLACE_SUBTRACT 14 STORE_GLOBAL 0 (zero) 16 LOAD_CONST 0 (None) 18 RETURN_VALUE

zero += 1操作 對(duì)應(yīng):

12 INPLACE_SUBTRACT14 STORE_GLOBAL 0 (zero)

zero -= 1操作 對(duì)應(yīng):

4 INPLACE_ADD6 STORE_GLOBAL 0 (zero)

這一行的代碼其實(shí)在解釋器中是分兩次去執(zhí)行的,在多線程的情況下就可能導(dǎo)致「計(jì)算」(INPLACE_ADD)完成了但是線程切換到別處去了,「賦值」STORE_GLOBAL沒有按順序被執(zhí)行到,所以引起了線程非安全操作。

「看完線程非安全操作的dis代碼,我們?cè)倏纯淳€程安全操作的dis代碼:」

from dis import dislst = []def operation(): global lst    lst.append("maishu")    lst.pop()dis(operation)

運(yùn)行代碼:

26 0 LOAD_GLOBAL 0 (lst) 2 LOAD_METHOD 1 (append) 4 LOAD_CONST 1 ('maishu') 6 CALL_METHOD 1 8 POP_TOP 27 10 LOAD_GLOBAL 0 (lst) 12 LOAD_METHOD 2 (pop) 14 CALL_METHOD 0 16 POP_TOP 18 LOAD_CONST 0 (None) 20 RETURN_VALUE

lst.append("maishu")操作 對(duì)應(yīng):

8 POP_TOP

lst.pop()操作 對(duì)應(yīng):

16 POP_TOP

只有一行語句就完成了對(duì)lst的操作,所以不怕線程怎么去切換。

不信?

上多線程,再把鎖去了跑幾次:

import threadinglst = []def operation(): global lst for i in range(3000000):        lst.append("maishu")        lst.pop()        th1 = threading.Thread(target = operation)th2 = threading.Thread(target = operation)th1.start()th2.start()th1.join()th2.join()print(lst)

運(yùn)行N次之后:

附錄

附上常見的線程安全操作和線程非安全操作

線程安全操作

L.append(x)L1.extend(L2)x = L[i]x = L.pop()L1[i:j] = L2L.sort()x = yx.field = yD[x] = yD1.update(D2)D.keys()

線程非安全操作

i = i+1L.append(L[-1])L[i] = L[j]D[x] = D[x] + 1

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

若不方便掃碼,搜微信號(hào):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)證碼對(duì)象,之后可以使用它調(diào)用相應(yīng)的接口 initGeetest({ // 以下 4 個(gè)配置參數(shù)為必須,不能缺少 gt: data.gt, challenge: data.challenge, offline: !data.success, // 表示用戶后臺(tái)檢測極驗(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ù)說明請(qǐng)參見: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 = '請(qǐng)輸入'+oInput.attr('placeholder')+'!'; var errTxt = '請(qǐng)輸入正確的'+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); }