摘要:如果有兩個(gè)線程都對(duì)方法進(jìn)行了操作,比如線程加線程加我們的預(yù)期結(jié)果是。由于線程的訪問(wèn)順序以及切換的時(shí)間是不可預(yù)期的在特定的訪問(wèn)順序下,可能出現(xiàn)一些出乎意料的結(jié)果比如下文中的執(zhí)行順序。
個(gè)人介紹
Java愛(ài)好者,個(gè)人網(wǎng)站: http://kailuncen.me/about/
前言這幾天學(xué)習(xí)并發(fā)編程,race-conditions-and-critical-sections,翻譯一下,寫點(diǎn)自己的筆記并加上點(diǎn)個(gè)人的理解。
網(wǎng)頁(yè)中里中提到兩個(gè)名詞Race Condition 和 Critical Section,接下來(lái)對(duì)他們進(jìn)行解釋和例子演示。
Race Condition在多線程場(chǎng)景下,當(dāng)多個(gè)線程訪問(wèn)同一塊資源,且執(zhí)行結(jié)果與線程訪問(wèn)的先后順序相關(guān),即表明這里面存在著Race Condition,中文翻譯即競(jìng)爭(zhēng)條件。
看下面?的代碼,多個(gè)線程都會(huì)調(diào)用add方法對(duì)同一個(gè)count值進(jìn)行加法。
public class Counter { protected long count = 0; public void add(long value){ this.count = this.count + value; } }
然而,add方法中的加法需要好幾個(gè)步驟才能完成。
1. 從內(nèi)存中讀取count的值到寄存器。 2. 加value。 3. 寫回內(nèi)存。
如果有兩個(gè)線程都對(duì)add方法進(jìn)行了操作,比如線程A加3,線程B加2,我們的預(yù)期結(jié)果是5。由于線程的訪問(wèn)順序以及切換的時(shí)間是不可預(yù)期的,在特定的訪問(wèn)順序下,可能出現(xiàn)一些出乎意料的結(jié)果,比如下文中的執(zhí)行順序。
A: Reads this.count into a register (0) B: Reads this.count into a register (0) B: Adds value 2 to register B: Writes register value (2) back to memory. this.count now equals 2 A: Adds value 3 to register A: Writes register value (3) back to memory. this.count now equals 3
由于加法不是原子性的,在加法執(zhí)行過(guò)程中的每一步都可能存在著線程切換。
比如線程A和B都先后讀到0,然后線程B占用了時(shí)間片完成了加2的操作,寫回了內(nèi)存,此時(shí)內(nèi)存中count的值等于2。
然后線程A重新得到調(diào)度,此時(shí)線程A內(nèi)部的count值還是0,線程A對(duì)主內(nèi)存內(nèi)count的變化是不可見的,然后線程完成加3操作,寫回內(nèi)存,此時(shí)count值等于3。
上述代碼中的add方法內(nèi)部就存在著競(jìng)爭(zhēng)條件,會(huì)根據(jù)線程執(zhí)行順序的不確定性影響最后的執(zhí)行結(jié)果。
Critical Section我們把會(huì)導(dǎo)致Race Condition的區(qū)域稱為Critical Section,中文翻譯臨界區(qū)。臨界區(qū)即每個(gè)線程中訪問(wèn)臨界資源的那段代碼。
在上文的代碼中,this.count就是臨界資源
this.count = this.count + value
就是臨界區(qū),為了保證執(zhí)行結(jié)果的正確性,避免臨界區(qū)內(nèi)產(chǎn)生競(jìng)爭(zhēng)條件,我們需要確保臨界區(qū)內(nèi)的執(zhí)行是原子的,每次僅允許一個(gè)線程進(jìn)去,進(jìn)入后不允許其他線程進(jìn)入。
我們可以采用線程同步做到以上的要求,線程同步可以使用synchronized同步代碼,或者locks,或者是原子變量比如AtomicInteger等。
可以把整個(gè)臨界區(qū)使用synchronized同步,但把臨界區(qū)拆分成多個(gè)小的臨界區(qū)能夠降低對(duì)共享資源的爭(zhēng)奪,增加整個(gè)臨界區(qū)的吞吐量,下面舉個(gè)例子。
public class TwoSums { private int sum1 = 0; private int sum2 = 0; public void add(int val1, int val2){ synchronized(this){ this.sum1 += val1; this.sum2 += val2; } } }
在上述代碼中,簡(jiǎn)單的做法就是鎖住整個(gè)對(duì)象,只有一個(gè)線程能夠執(zhí)行兩個(gè)不同變量的加法操作。然而,由于這兩個(gè)變量是互相獨(dú)立的,可以拆分到兩個(gè)不同的synchronized塊中。
public class TwoSums { private int sum1 = 0; private int sum2 = 0; private Integer sum1Lock = new Integer(1); private Integer sum2Lock = new Integer(2); public void add(int val1, int val2){ synchronized(this.sum1Lock){ this.sum1 += val1; } synchronized(this.sum2Lock){ this.sum2 += val2; } } }
改動(dòng)后,兩個(gè)線程可以同時(shí)在add方法中操作,一個(gè)線程在第一個(gè)synchronized塊,另一個(gè)線程在第二個(gè)synchronized塊,兩個(gè)synchronized塊同步的是不同的對(duì)象,所以兩個(gè)線程可以獨(dú)立執(zhí)行,整體線程等待的時(shí)間會(huì)變少,吞吐量能夠得到提升。
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://systransis.cn/yun/70371.html
摘要:共享數(shù)據(jù)使線程之間的通信比進(jìn)程之間的通信更有效。并發(fā)模型和的區(qū)別說(shuō)明的作用是啟動(dòng)一個(gè)新線程操作系統(tǒng)級(jí)別,有一個(gè)方法啟動(dòng)新線程,新線程會(huì)執(zhí)行相應(yīng)的方法。單獨(dú)調(diào)用會(huì)在當(dāng)前線程中執(zhí)行并不會(huì)啟動(dòng)新線程創(chuàng)建一個(gè)線程即可但是這個(gè)線程沒(méi)有執(zhí)行任何代碼段。 tutorials site 并發(fā)Concurrency發(fā)展的歷史 單CPU,一次只能運(yùn)行一個(gè)程序 -- 多任務(wù),一次同時(shí)運(yùn)行多個(gè)任...
摘要:當(dāng)其他線程調(diào)用時(shí),它們被阻塞,直到第一個(gè)線程釋放鎖對(duì)象。包關(guān)于獲取這個(gè)鎖如果鎖同時(shí)被另一個(gè)線程擁有則發(fā)生阻塞。所以必須確保沒(méi)有其他線程再檢查余額和轉(zhuǎn)賬活動(dòng)之間修改金額。方法添加一個(gè)線程到等待集中,方法解除等待線程的阻塞狀態(tài)。 避免代碼塊受到并發(fā)訪問(wèn)的干擾 java語(yǔ)言提供了兩種機(jī)制實(shí)現(xiàn)這種功能 Synchonized 關(guān)鍵字(調(diào)用對(duì)象內(nèi)部的鎖) synchronized關(guān)鍵字自動(dòng)...
閱讀 1140·2021-09-22 15:32
閱讀 1735·2019-08-30 15:53
閱讀 3268·2019-08-30 15:53
閱讀 1420·2019-08-30 15:43
閱讀 465·2019-08-28 18:28
閱讀 2584·2019-08-26 18:18
閱讀 677·2019-08-26 13:58
閱讀 2540·2019-08-26 12:10