二、安全公布
到眼下為止,我們重點討論的是怎樣確保對象不被公布,比如讓對象封閉在線程或還有一個對象的內部。當然,在某些情況下我們希望在多個線程間共享對象,此時必須確保安全地進行共享。然而,假設僅僅是像以下程序那樣將對象引用保存到公有域中,那么還不足以安全地公布這個對象。
//不安全的公布
public Holder holder;
public void initialize() {
holder = new Holder(42);
}
你可能會奇怪。這個看似沒有問題的演示樣例何以會執行失敗。
因為存在可見性問題,其它線程看到的Holder對象將處于不一致的狀態,即便在該對象的構造函數中已經正確地構建了不變性條件。這樣的不對的公布導致其它線程看到尚未創建完畢的對象。
不對的公布:正確的對象被破壞
你不能指望一個尚未被全然創建的對象擁有完整性。某個觀察該對象的線程將看到對象處于不一致的狀態。然后看到對象的狀態突然發生變化,即使線程在對象公布后還沒有改動過它。其實,假設以下程序中的Holder使用前面程序中的不安全公布方式,那么還有一個線程在調用assertSanity時將拋出AssertionError。
public class Holder {
private int n;
public Holder(int n) { this.n = n; }
public void assertSanity() {
if (n != n)
throw new AssertionError("This statement is false.");
}
}
因為沒有使用同步來確保Holder對象對其它線程可見,因此將Holder稱為“未被正確公布”。在未被正確公布的對象中存在兩個問題。
首先,除了公布對象的線程外,其它線程能夠看到的Holder域是一個失效值。因此將看到一個空引用或者之前的舊值。
然而,更糟糕的情況是,線程看到Holder引用的值是最新的,但Holder狀態的值卻是失效的。情況變得更加不可預測的是,某個線程在第一次讀取域時得到失效值,而再次讀取這個域時會得到一個更新值。這也是assertSainty拋出AssertionError的原因。
假設沒有足夠的同步,那么當在多個線程間共享數據時將發生一些很奇怪的事情。
不可變對象與初始化安全性
因為不可變對象是一種很重要的對象,因此Java內存模型為不可變對象的共享提供了一種特殊的初始化安全性保證。我們已經知道,即使某個對象的引用對其它線程是可見的,也并不意味著對象狀態對于使用該對象的線程來說一定是可見的。為了確保對象狀態能呈現出一致的視圖,就必須使用同步。
還有一方面。即使在公布不可變對象的引用時沒有使用同步,也仍然能夠安全地訪問該對象。
為了維持這樣的初始化安全性的保證。必須滿足不可變性的全部需求:狀態不可改動,全部域都是final類型。以及正確的構造過程。(假設Holder對象是不可變的,那么即使Holder沒有被正確地公布。在assertSanity中也不會拋出AssertionError。
)
不論什么線程都能夠在不須要額外同步的情況下安全地訪問不可改變對象,即使在公布這些對象時沒有使用同步。
這樣的保證還將延伸到被正確創建對象中全部final類型的域。在沒有額外同步的情況下,也能夠安全地訪問final類型的域。然而。假設final類型的域所指向的是可變對象。那么在訪問這些域所指向的對象的狀態時仍然須要同步。
安全公布的經常使用模式
可變對象必須通過安全的方式來公布,這通常意味著在公布和使用該對象的線程時都必須使用同步。
如今,我們將重點介紹怎樣確保使用對象的線程可以看到該對象處于已公布的狀態。并稍后介紹怎樣在對象公布后對其可見性進行改動。
安全地公布一個對象。對象的應用以及對象的狀態必須同一時候對其它線程可見。一個正確構造的對象能夠通過下面方式來安全地公布:
在靜態初始化函數中初始化一個對象引用
將對象的應用保存到volatile類型的域或者AtomicReferance對象中
將對象的引用保存到某個正確構造對象的final類型域中
將對象的引用保存到一個由鎖保護的域中。
在線程安全容器內部的同步意味著,在將對象放入到某個容器。比如Vector或synchronizedList時,將滿足上述最后一條需求。假設線程A將對象X放入一個線程安全的容器。隨后線程B讀取這個對象,那么能夠確保B看到A設置的X狀態,即便在這段讀/寫X的應用程序代碼中沒有包括顯式的同步。雖然Javadoc在這個主題上沒有給出非常清晰的說明,但線程安全庫中的容器類提供了下面的安全公布保證:
通過將一個鍵或者值放入Hashtable、synchronizedMap或者ConcurrentMap中,能夠安全地將它公布給不論什么從這些容器中訪問它的線程(不管是直接訪問還是通過迭代器訪問)
通過將某個元素放入Vector、CopyOnWriteArrayList、CopyOnWriteArraySet、synchronizedList或synchronizedSet中,能夠將該元素安全地公布到不論什么從這些容器中訪問該元素的線程
通過將某個元素放入BlockingQueue或者ConcurrentLinkedQueue中,能夠將該元素安全地公布到不論什么從這些隊列中訪問該元素的線程。
類庫中的其它數據傳遞機制(比如Future和Exchanger)相同能實現安全公布。在介紹這些機制時將討論它們的安全公布功能。
通常,要公布一個靜態構造的對象,最簡單和最安全的方式是使用靜態的初始化器:
public static Holder holder = new Holder(42);
靜態初始化器由JVM在類的初始化階段運行。
因為在JVM內部存在著同步機制,因此通過這樣的方式初始化的不論什么對象都能夠被安全地公布[JLS 12.4.2]。
事實不可變對象
假設對象在公布后不會被改動,那么對于其它在沒有額外同步的情況下安全地訪問這些對象的線程來說,安全公布是足夠的。全部的安全公布機制都能確保。當對象的引用對全部訪問該對象的線程可見時,對象公布時的狀態對于全部線程也將是可見的,而且假設對象狀態不會再改變,那么就足以確保不論什么訪問都是安全的。
假設對象從技術上來看是可變的,但其狀態在公布后不會再改變。那么把這樣的對象稱為“事實不可變對象(Effectively Immutable Object)”。這些對象不須要滿足之前提出的不可變性的嚴格定義。在這些對象公布后。程序僅僅需將它們視為不可變對象就可以。通過使用事實不可變對象。不僅能夠簡化開發過程,并且還能因為降低了同步而提高性能。
在沒有額外的同步的情況下,不論什么線程都能夠安全地使用被安全公布的事實不可變對象。
比如,Date本身是可變的,但如果將它作為不可變對象來使用,那么在多個線程之間共享Date對象時,就能夠省去對鎖的使用。
如果須要維護一個Map對象,當中保存了每位用戶的近期登錄時間:
public Map lastLogin =Collections.synchronizedMap(new HashMap());
假設Date對象的值在被放入Map后就不會改變,那么synchronizedMap中的同步機制就足以使Date值被安全地公布。而且在訪問這些Date值時不須要額外的同步。
可變對象
假設對象在構造后能夠改動,那么安全公布僅僅能確保“公布當時”狀態的可見性。對于可變對象,不僅在公布對象時須要使用同步,并且在每次對象訪問時相同須要使用同步來確保興許改動操作的可見性。
要安全地共享可變對象。這些對象就必須被安全地公布。并且必須是線程安全的或者由某個鎖保護起來。
對象的公布需求取決于它的可變性:
不可變對象能夠通過隨意機制來公布
事實不可改變必須通過安全方式公布
可變對象必須通過安全方式公布。而且必須是線程安全的或者由某個鎖保護起來
安全的共享對象
當獲得對象的一個引用時,你須要知道在這個引用上能夠運行哪些操作。
在使用它之前是否須要獲得一個鎖?能否夠改動它的狀態,或者僅僅能讀取它?很多并發錯誤都是因為沒有理解共享對象的這些“既定規則”而導致的。當公布一個對象時,必須明白地說明對象的訪問方式。