編寫高效的線程安全類
發(fā)表時間:2024-05-22 來源:明輝站整理相關(guān)軟件相關(guān)文章人氣:
[摘要]Java 編程語言為編寫多線程應(yīng)用程序提供強大的語言支持。但是,編寫有用的、沒有錯誤的多線程程序仍然比較困難。本文試圖概述幾種方法,程序員可用這幾種方法來創(chuàng)建高效的線程安全類。 并發(fā)性 只有當(dāng)要解決的問題需要一定程度的并發(fā)性時,程序員才會從多線程應(yīng)用程序中受益。例如,如果打印隊列應(yīng)用程序僅...
Java 編程語言為編寫多線程應(yīng)用程序提供強大的語言支持。但是,編寫有用的、沒有錯誤的多線程程序仍然比較困難。本文試圖概述幾種方法,程序員可用這幾種方法來創(chuàng)建高效的線程安全類。
并發(fā)性 只有當(dāng)要解決的問題需要一定程度的并發(fā)性時,程序員才會從多線程應(yīng)用程序中受益。例如,如果打印隊列應(yīng)用程序僅支持一臺打印機和一臺客戶機,則不應(yīng)該將它編寫為多線程的。一般說來,包含并發(fā)性的編碼問題通常都包含一些可以并發(fā)執(zhí)行的操作,同時也包含一些不可并發(fā)執(zhí)行的操作。例如,為多個客戶機和一個打印機提供服務(wù)的打印隊列可以支持對打印的并發(fā)請求,但向打印機的輸出必須是串行形式的。多線程實現(xiàn)還可以改善交互式應(yīng)用程序的響應(yīng)時間。
Synchronized 關(guān)鍵字
雖然多線程應(yīng)用程序中的大多數(shù)操作都可以并行進行,但也有某些操作(如更新全局標(biāo)志或處理共享文件)不能并行進行。在這些情況下,必須獲得一個鎖來防止其他線程在執(zhí)行此操作的線程完成之前訪問同一個方法。在 Java 程序中,這個鎖是通過 synchronized 關(guān)鍵字提供的。清單 1 說明了它的用法。
清單 1. 使用 synchronized 關(guān)鍵字來獲取鎖
public class MaxScore {
int max;
public MaxScore() {
max = 0;
}
public synchronized void currentScore(int s) {
if(s> max) {
max = s;
}
}
public int max() {
return max;
}
}
這里,兩個線程不能同時調(diào)用 currentScore() 方法;當(dāng)一個線程工作時,另一個線程必須阻塞。但是,可以有任意數(shù)量的線程同時通過 max() 方法訪問最大值,因為 max() 不是同步方法,因此它與鎖定無關(guān)。
試考慮在 MaxScore 類中添加另一個方法的影響,該方法的實現(xiàn)如清單 2 所示。
清單 2. 添加另一個方法
public synchronized void reset() {
max = 0;
}
這個方法(當(dāng)被訪問時)不僅將阻塞 reset() 方法的其他調(diào)用,而且也將阻塞 MaxScore 類的同一個實例中的 currentScore() 方法,因為這兩個方法都訪問同一個鎖。如果兩個方法必須不彼此阻塞,則程序員必須在更低的級別使用同步。清單 3 是另一種情況,其中兩個同步的方法可能需要彼此獨立。
清單 3. 兩個獨立的同步方法
import java.util.*;
public class Jury {
Vector members;
Vector alternates;
public Jury() {
members = new Vector(12, 1);
alternates = new Vector(12, 1);
}
public synchronized void addMember(String name) {
members.add(name);
}
public synchronized void addAlt(String name) {
alternates.add(name);
}
public synchronized Vector all() {
Vector retval = new Vector(members);
retval.addAll(alternates);
return retval;
}
}
此處,兩個不同的線程可以將 members 和 alternates 添加到 Jury 對象中。請記住,synchronized 關(guān)鍵字既可用于方法,更一般地,也可用于任何代碼塊。清單 4 中的兩段代碼是等效的。
清單 4. 等效的代碼
synchronized void f() {
void f() {
// 執(zhí)行某些操作
synchronized(this) {
}
// 執(zhí)行某些操作
}
}
所以,為了確保 addMember() 和 addAlt() 方法不彼此阻塞,可按清單 5 所示重寫 Jury 類。
清單 5. 重寫后的 Jury 類
import java.util.*;
public class Jury {
Vector members;
Vector alternates;
public Jury() {
members = new Vector(12, 1);
alternates = new Vector(12, 1);
}
public void addMember(String name) {
synchronized(members) {
members.add(name);
}
}
public void addAlt(String name) {
synchronized(alternates) {
alternates.add(name);
}
}
public Vector all() {
Vector retval;
synchronized(members) {
retval = new Vector(members);
}
synchronized(alternates) {
retval.addAll(alternates);
}
return retval;
}
}
請注意,我們還必須修改 all() 方法,因為對 Jury 對象同步已沒有意義。在改寫后的版本中,addMember()、addAlt() 和 all() 方法只訪問與 members 和 alternates 對象相關(guān)的鎖,因此鎖定 Jury 對象毫無用處。另請注意,all() 方法本來可以寫為清單 6 所示的形式。
清單 6. 將 members 和 alternates 用作同步的對象
public Vector all() {
synchronized(members) {
synchronized(alternates) {
Vector retval;
retval = new Vector(members);
retval.addAll(alternates);
}
}
return retval;
}
但是,因為我們早在需要之前就獲得 members 和 alternates 的鎖,所以這效率不高。清單 5 中的改寫形式是一個較好的示例,因為它只在最短的時間內(nèi)持有鎖,并且每次只獲得一個鎖。這樣就完全避免了當(dāng)以后增加代碼時可能產(chǎn)生的潛在死鎖問題。