信不信?以面向?qū)ο蟮乃枷胧强梢詫懞酶卟l(fā)程序的!
來自:冰河技術(shù)
前言
那我們?nèi)绾卫妹嫦驅(qū)ο蟮乃枷雽懞貌l(fā)程序呢?我們可以從下面三個角度進(jìn)行分析。
封裝共享變量
識別共享變量間的約束條件
指定并發(fā)訪問策略
封裝共享變量
在編寫并發(fā)程序時,我們關(guān)注的一個核心問題,其實就是解決多線程同時訪問共享變量的問題!
面向?qū)ο笏枷胫杏幸粋€很重要的特性:封裝。簡單的說,封裝就是將屬性和實現(xiàn)細(xì)節(jié)封裝到對象的內(nèi)部,外界對象只能通過目標(biāo)對象提供的公共方法來間接訪問內(nèi)部屬性。我們把共享變量作為對象的屬性,那么,對于共享變量的訪問路徑就是對象的公共方法,所有公共方法的入口都要設(shè)置并發(fā)訪問策略。
所以,我們得出一個結(jié)論:利用面向?qū)ο?/a>思想寫并發(fā)程序其實挺簡單,就是將共享變量作為對象屬性封裝在內(nèi)部,對所有的公共方法指定并發(fā)訪問策略!
比如,我們在很多業(yè)務(wù)場景中都會用到計數(shù)器,我們可以將計數(shù)器類定義成如下所示。
public class Counter{
private long count;
public synchronized long incrementCount(){
return ++count;
}
public synchronized long getCount(){
return count;
}
}
在上面的Counter類中,存在一個共享變量count,對外提供的兩個公共方法incrementCount()和getCount()設(shè)置了synchronized同步鎖,此時,Counter類就是一個線程安全的類了。
在實際工作中,很多場景比計數(shù)器的實現(xiàn)復(fù)雜的多,比如,我們的銀行賬戶中,有卡號、姓名、身份證、余額等共享變量,我們沒有必要對每個共享變量都要考慮并發(fā)問題。此時,我們就需要仔細(xì)分析這些共享變量,看這些共享變量中哪些變量是不變的。對于我們的銀行賬戶來說,卡號、姓名、身份證這三個共享變量就是不變的。對于這些不變的共享變量,我們可以使用final關(guān)鍵字來修飾它們,避免并發(fā)問題。
最后,需要注意的是,對共享變量進(jìn)行封裝時,要注意”對象逃逸“的問題!例如,下面的程序代碼,在構(gòu)造函數(shù)中將this賦值給了全局變量global.obj,此時對象初始化還沒有完成,此時對象初始化還沒有完成,此時對象初始化還沒有完成,重要的事情說三遍!!線程通過global.obj讀取的x值可能為0。此時對象this就“逃逸”了。
final x = 0;
public FinalFieldExample() { // bad!
x = 3;
y = 4;
// bad construction - allowing this to escape
global.obj = this;
}
以上示例來源于:http://www.cs.umd.edu/~pugh/java/memoryModel/jsr-133-faq.html#finalWrong
識別共享變量間的約束條件
共享變量間的約束條件非常重要,因為它們決定了并發(fā)訪問策略。
例如,在商城業(yè)務(wù)中,對于商品的庫存管理中有個合理庫存的概念,庫存量不能太高,也不能太低,這個值有一個上限和一個下限。例如,下面的類模擬了這個合理的庫存概念。
public class Stock{
//庫存的上限
private final AtomicLong upper = new AtomicLong(0);
//庫存的下限
private final AtomicLong lower = new AtomicLong(0);
//設(shè)置庫存上限
public void setUpper(long v){
upper.set(v);
}
//設(shè)置庫存下限
public void setLower(long v){
lower.set(v);
}
//其他眾多的代碼省略
}
乍一看,上面的程序沒問題?。〉?,其忽略了一個約束條件,就是庫存的下限要小于庫存的上限。這也是很多人容易忽略的問題。
看到這里,很多人的第一反應(yīng)就是在setUpper()方法和setLower()方法中,添加參數(shù)校驗邏輯,例如,改造后的Stock類如下所示。
public class Stock{
//庫存的上限
private final AtomicLong upper = new AtomicLong(0);
//庫存的下限
private final AtomicLong lower = new AtomicLong(0);
//設(shè)置庫存上限
public void setUpper(long v){
if(v < lower.get()){
throw new IllegalArgumentException();
}
upper.set(v);
}
//設(shè)置庫存下限
public void setLower(long v){
if(v > upper.get()){
throw new IllegalArgumentException();
}
lower.set(v);
}
//其他眾多的代碼省略
}
這樣設(shè)置正確嗎?答案是:這樣設(shè)置完全不同保證庫存的下限小于庫存的上限。
其實,這里存在競態(tài)條件(當(dāng)程序中出現(xiàn) if 語句的時候,應(yīng)該首先反應(yīng)出程序是否有競態(tài)條件),關(guān)于競態(tài)條件的詳細(xì)講解可以參見《【高并發(fā)】要想學(xué)好并發(fā)編程,關(guān)鍵是要理解這三個核心問題》。
假設(shè),原有庫存的上限為10,下限為3。此時線程A調(diào)用setUpper(5)將庫存的上限設(shè)置為5,線程B調(diào)用setLower(7)將庫存的下限設(shè)置為8,如果線程A和線程B同時執(zhí)行,線程A會通過參數(shù)校驗,因為此時庫存的下限還沒有被線程B設(shè)置完畢,此時的庫存下限還是3,5>3成立,所以,線程A會將庫存的上限設(shè)置為5。同樣的,線程B也能夠通過參數(shù)校驗,因為此時庫存的上限還沒有被線程A設(shè)置完畢,此時庫存的上限還是10,8<10成立,線程B會將庫存的下限設(shè)置為8。最終的結(jié)果為:庫存的上限為5,下限為8。庫存的上限小于下限,不滿足上限小于下限的約束條件。
所以,大家在識別共享變量間的約束條件時,一定要注意競態(tài)條件的問題!
制定并發(fā)訪問策略
制定并發(fā)訪問策略比較復(fù)雜,它需要結(jié)合具體的業(yè)務(wù)場景進(jìn)行選擇。但是從方案上,我們可以將其總結(jié)成如下方案。
避免共享
可以利用線程本地存儲和為每個任務(wù)分配獨(dú)立的線程來避免共享。
不變模式
這個在Java中使用的比較少,在其他的領(lǐng)域使用的比較多,例如Actor模式,CSP模式和函數(shù)式編程。
管程和其他同步工具
Java中對于并發(fā)編程萬能的解決方案就是管程(關(guān)于什么是管程后面的文章會講解),但是對于很多特定的并發(fā)場景來說,使用Java并發(fā)包提供的讀寫鎖、并發(fā)容器等同步工具比較好。
我們在編寫并發(fā)程序時,也要遵循一定的原則,這些原則可以歸納如下。
優(yōu)先使用成熟的工具類
對于并發(fā)編程來說,我們最好優(yōu)先使用Java中提供的并發(fā)工具類,因為這些并發(fā)工具類基本上能夠滿足大部分并發(fā)的業(yè)務(wù)場景。
盡量不要使用低級的同步原語
低級的同步原語指的是synchronized,Lock和Semaphore等,這些使用起來雖然簡單,但實際上并沒有那么簡單,使用的時候一定要小心。不到萬不得已的時候,盡量不要使用它們。
避免過早優(yōu)化
安全第一,并發(fā)編程首先要保證的就是線程安全,出現(xiàn)性能瓶頸之后再優(yōu)化,不要過早和過度的優(yōu)化。
寫在最后
最后,附上并發(fā)編程需要掌握的核心技能知識圖,祝大家在學(xué)習(xí)并發(fā)編程時,少走彎路。
特別推薦一個分享架構(gòu)+算法的優(yōu)質(zhì)內(nèi)容,還沒關(guān)注的小伙伴,可以長按關(guān)注一下:
長按訂閱更多精彩▼
如有收獲,點(diǎn)個在看,誠摯感謝
免責(zé)聲明:本文內(nèi)容由21ic獲得授權(quán)后發(fā)布,版權(quán)歸原作者所有,本平臺僅提供信息存儲服務(wù)。文章僅代表作者個人觀點(diǎn),不代表本平臺立場,如有問題,請聯(lián)系我們,謝謝!