Java網絡程序設計 課件 單元8-04 共享數據

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

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

8.4.2控制共享數據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的數據是："+data++);}catch(InterruptedExceptione){e.printStackTrace();}}}}}

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

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

synchronized(obj){

//同步代碼塊

}要想實現線程的同步，則這些線程必須去競爭一個唯一的共享的對象鎖。示例代碼：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;//構造方法引入競爭對象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);}}}}運行結果8.4.3多線程同步publicclassTestSyncThread3{publicstaticvoidmain(String[]args){for(inti=0;i<5;i++){NewThrea(newSyncThread(i).start();}}}ClassSyncThreadimplementsjava.lang.Runnable{Privateinttid;示例代碼：//在線程類內部定義一個靜態(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);}}}}

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

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

//同步方法體內代碼塊

}每個類實例都對應一把鎖，每個synchronized方法都必須獲得調用該方法的類實例的鎖方能執(zhí)行，否則所屬線程阻塞。synchronized方法一旦執(zhí)行，就獨占該鎖，直到該方法返回時才將鎖釋放，此后被阻塞的線程方能獲得該鎖，重新進入就緒狀態(tài)。這種機制確保了同一時刻對于每一個類實例，其所有聲明為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