Java網(wǎng)絡(luò)程序設(shè)計 課件 單元8-04 共享數(shù)據(jù)

線程應(yīng)用單元八目錄CONTENTS123多線程創(chuàng)建和使用線程線程控制線程死鎖和協(xié)作目錄CONTENTS5共享數(shù)據(jù)4publicclassShareData{staticintdata=0;publicstaticvoidmain(String[]args){ShareThreadlst1=newShareThread1();ShareThread2st2=newShareThread2();newThread(stl).start();newThread(st2).start();}//內(nèi)部類，訪問類中靜態(tài)成員變量dataprivatestaticclassShareThreadlimplementsRunnable{publicvoidrun(){while(data<10){try{Thread.sleep(l000);System.out.println("這個小于10的數(shù)據(jù)是："+data++);}catch(InterruptedExceptione){e.printStackTrace();}}}}示例代碼：8.4.1數(shù)據(jù)不一致//內(nèi)部類，訪問類中靜態(tài)成員變量dataprivatestaticclassShareThread2implementsRunnable{publicvoidrun(){while(data<100){data++;}}}}

該案例說明當(dāng)一個數(shù)據(jù)被多個線程存取的時候，通過檢查這個數(shù)據(jù)的值來進(jìn)行判斷并執(zhí)行之后的操作是極不安全的。因?yàn)樵谂袛嘀?，這個數(shù)據(jù)的值很可能被其他線程修改了，判斷條件也可能已經(jīng)不成立了，但此時已經(jīng)經(jīng)過了判斷，之后的操作還需要繼續(xù)進(jìn)行。

8.4.2控制共享數(shù)據(jù)publicclassShareData2{staticintdata=0;//定義了一個鎖對象lockstaticfinalObjectlock=newObject();publicstaticvoidmain(String[]args){ShareThread1st1=newShareThread1();ShareThread2st2=newShareThread2();newThread(st1).start();newThread(st2).start();}示例代碼：privatestaticclassShareThread1implementsRunnable{publicvoidrun(){//對lock對象上鎖synchronized(lock){while(data<10){try{Thread.sleep(l000);System.out.println("這個小于10的數(shù)據(jù)是："+data++);}catch(InterruptedExceptione){e.printStackTrace();}}}}}

Java提供了同步機(jī)制，來解決控制共享數(shù)據(jù)的問題，Java可以使用synchronized關(guān)鍵字確保數(shù)據(jù)在各個線程間正確共享。8.4.2控制共享數(shù)據(jù)privatestaticclassShareThread2implementsRunnable{publicvoidrun(){//對lock對象上鎖synchronized(lock){while(data<100){data++；}System.out.println("ShareThread2執(zhí)行完后data的值為："+data);}}}}運(yùn)行結(jié)果8.4.3多線程同步

多線程同步依靠的是對象鎖機(jī)制，synchronized關(guān)鍵字就是利用鎖來實(shí)現(xiàn)對共享資源的互斥訪問。實(shí)現(xiàn)多線程同步的方法之一就是同步代碼塊，其語法形式如下：

synchronized(obj){

//同步代碼塊

}要想實(shí)現(xiàn)線程的同步，則這些線程必須去競爭一個唯一的共享的對象鎖。示例代碼：publicclassTestSyncThread{publicstaticvoidmain(String[]args){for(inti=0;i<5;i++){newThread(newSyncThread(i)).start();}}}classSyncThreadimplementsjava.lang.Runnable{privateinttid;publicSyncThread(intid){this.tid=id;}publicvoidrun(){for(inti=0;i<10;i++){System.out.println("線程ID名為："+this.tid+"正在輸出："+i);}}}8.4.3多線程同步publicclassTestSyncThread2{publicstaticvoidmain(String[]args){//創(chuàng)建一個線程之間競爭使用的對象Objectobj=newObject();for(inti=0;i<5;i++){newThread(newSyncThread(i,obj)).start();}}}示例代碼：classSyncThreadimplementsjava.lang.Runnable{privateinttid;privateObjectlock;//構(gòu)造方法引入競爭對象publicSyncThread(intid,Objectobj){this.tid=id;this.lock=obj;}

修改TestSyncThread類，在創(chuàng)建、啟動線程之前，先創(chuàng)建一個線程之間競爭使用的對象，然后將這個對象的引用傳遞給每一個線程對象的lock成員變量。8.4.3多線程同步publicvoidrun(){synchronized(lock){for(inti=0;i<10;i++){System.out.println("線程ID名為："+this.tid+"正在輸出："+i);}}}}運(yùn)行結(jié)果8.4.3多線程同步publicclassTestSyncThread3{publicstaticvoidmain(String[]args){for(inti=0;i<5;i++){NewThrea(newSyncThread(i).start();}}}ClassSyncThreadimplementsjava.lang.Runnable{Privateinttid;示例代碼：//在線程類內(nèi)部定義一個靜態(tài)共享資源.lockprivatestaticObjectlock=newObject();publicSyncThread(intid){this.tid=id;}Publicvoidrun(){synchronized(lock){for(inti=0;i<10;i++){System.out.println("線程ID名為："+this.tid+"正在輸出："+i);}}}}

利用類變量被所有類的實(shí)例所共享這一特性，在線程類內(nèi)部定義一個靜態(tài)共享資源，通過對這個共享資源的競爭起到線程同步的目的。8.4.3多線程同步8.4.3多線程同步實(shí)現(xiàn)多線程同步的方法之二就是同步方法，其語法形式如下：

訪問修飾符synchronized返回類型方法名{

//同步方法體內(nèi)代碼塊

}每個類實(shí)例都對應(yīng)一把鎖，每個synchronized方法都必須獲得調(diào)用該方法的類實(shí)例的鎖方能執(zhí)行，否則所屬線程阻塞。synchronized方法一旦執(zhí)行，就獨(dú)占該鎖，直到該方法返回時才將鎖釋放，此后被阻塞的線程方能獲得該鎖，重新進(jìn)入就緒狀態(tài)。這種機(jī)制確保了同一時刻對于每一個類實(shí)例，其所有聲明為synchronized的方法中至多只有一個處于就緒狀態(tài)，從而有效避免了類成員變量的訪問沖突。示例代碼：publicclassTestSyncThread4{publicstaticvoidmain(String[]args){for(inti=0;i<5;i++){newThread(newSyncThread(i)).startO;}}}classSyncThreadimplementsjava.lang.Runnable{privateinttid;publicSyncThread(intid){this.tid=id;}p