1.7 Java 5.0多線(xiàn)程編程
Java自1995年面世以來(lái)得到了廣泛得一個(gè)運(yùn)用,但是對(duì)多線(xiàn)程編程的支持Java很長(zhǎng)時(shí)間一直停留在初級(jí)階段。在Java 5.0之前Java里的多線(xiàn)程編程主要是通過(guò)Thread類(lèi),Runnable接口,Object對(duì)象中的wait()、 notify()、 notifyAll()等方法和synchronized關(guān)鍵詞來(lái)實(shí)現(xiàn)的。這些工具雖然能在大多數(shù)情況下解決對(duì)共享資源的管理和線(xiàn)程間的調(diào)度,但存在以下幾個(gè)問(wèn)題
1. 過(guò)于原始,拿來(lái)就能用的功能有限,即使是要實(shí)現(xiàn)簡(jiǎn)單的多線(xiàn)程功能也需要編寫(xiě)大量的代碼。這些工具就像匯編語(yǔ)言一樣難以學(xué)習(xí)和使用,比這更糟糕的是稍有不慎它們還可能被錯(cuò)誤地使用,而且這樣的錯(cuò)誤很難被發(fā)現(xiàn)。
2. 如果使用不當(dāng),會(huì)使程序的運(yùn)行效率大大降低。
3. 為了提高開(kāi)發(fā)效率,簡(jiǎn)化編程,開(kāi)發(fā)人員在做項(xiàng)目的時(shí)候往往需要寫(xiě)一些共享的工具來(lái)實(shí)現(xiàn)一些普遍適用的功能。但因?yàn)闆](méi)有規(guī)范,相同的工具會(huì)被重復(fù)地開(kāi)發(fā),造成資源浪費(fèi)。
4. 因?yàn)殒i定的功能是通過(guò)Synchronized來(lái)實(shí)現(xiàn)的,這是一種塊結(jié)構(gòu),只能對(duì)代碼中的一段代碼進(jìn)行鎖定,而且鎖定是單一的。如以下代碼所示:
synchronized(lock){
//執(zhí)行對(duì)共享資源的操作
……
}
一些復(fù)雜的功能就很難被實(shí)現(xiàn)。比如說(shuō)如果程序需要取得lock A和lock B來(lái)進(jìn)行操作1,然后需要取得lock C并且釋放lock A來(lái)進(jìn)行操作2,Java 5.0之前的多線(xiàn)程框架就顯得無(wú)能為力了。
因?yàn)檫@些問(wèn)題,程序員對(duì)舊的框架一直頗有微詞。這種情況一直到Java 5.0才有較大的改觀,一系列的多線(xiàn)程工具包被納入了標(biāo)準(zhǔn)庫(kù)文件。這些工具包括了一個(gè)新的多線(xiàn)程程序的執(zhí)行框架,使編程人員可方便地協(xié)調(diào)和調(diào)度線(xiàn)程的運(yùn)行,并且新加入了一些高性能的常用的工具,使程序更容易編寫(xiě),運(yùn)行效率更高。本文將分類(lèi)并結(jié)合例子來(lái)介紹這些新加的多線(xiàn)程工具。
在我們開(kāi)始介紹Java 5.0里的新Concurrent工具前讓我們先來(lái)看一下一個(gè)用舊的多線(xiàn)程工具編寫(xiě)的程序,這個(gè)程序里有一個(gè)Server線(xiàn)程,它需要啟動(dòng)兩個(gè)Component,Server線(xiàn)程需等到Component線(xiàn)程完畢后再繼續(xù)。相同的功能在Synchronizer一章里用新加的工具CountDownLatch有相同的實(shí)現(xiàn)。兩個(gè)程序,孰優(yōu)孰劣,哪個(gè)程序更容易編寫(xiě),哪個(gè)程序更容易理解,相信大家看過(guò)之后不難得出結(jié)論。
public class ServerThread {
Object concLock = new Object();
int count = 2;
public void runTwoThreads() {
//啟動(dòng)兩個(gè)線(xiàn)程去初始化組件
new Thread(new ComponentThread1(this)).start();
new Thread(new ComponentThread1(this)).start();
// Wait for other thread
while(count != 0) {
synchronized(concLock) {
try {
concLock.wait();
System.out.println("Wake up.");
} catch (InterruptedException ie) { //處理異常}
}
}
System.out.println("Server is up.");
}
public void callBack() {
synchronized(concLock) {
count--;
concLock.notifyAll();
}
}
public static void main(String[] args){
ServerThread server = new ServerThread();
server.runTwoThreads();
}
}
public class ComponentThread1 implements Runnable {
private ServerThread server;
public ComponentThread1(ServerThread server) {
this.server = server;
}
public void run() {
//做組件初始化的工作
System.out.println("Do component initialization.");
server.callBack();
}
}
相關(guān)推薦:計(jì)算機(jī)等級(jí)考試二級(jí)Java經(jīng)典算法大全匯總北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |