java 多线程 共享数据_JAVA多线程提高四：多个线程之间共享数据的方式
多個線程訪問共享對象和數(shù)據(jù)的方式
如果每個線程執(zhí)行的代碼相同，可以使用同一個Runnable對象，這個Runnable對象中有那個共享數(shù)據(jù)，例如，買票系統(tǒng)就可以這么做。
如果每個線程執(zhí)行的代碼不同，這時候需要用不同的Runnable對象，有如下兩種方式來實現(xiàn)這些Runnable對象之間的數(shù)據(jù)共享：
?將共享數(shù)據(jù)封裝在另外一個對象中，然后將這個對象逐一傳遞給各個Runnable對象。每個線程對共享數(shù)據(jù)的操作方法也分配到那個對象身上去完成，這樣容易實現(xiàn)針對該數(shù)據(jù)進行的各個操作的互斥和通信。
?將這些Runnable對象作為某一個類中的內(nèi)部類，共享數(shù)據(jù)作為這個外部類中的成員變量，每個線程對共享數(shù)據(jù)的操作方法也分配給外部類，以便實現(xiàn)對共享數(shù)據(jù)進行的各個操作的互斥和通信，作為內(nèi)部類的各個Runnable對象調(diào)用外部類的這些方法。
?上面兩種方式的組合：將共享數(shù)據(jù)封裝在另外一個對象中，每個線程對共享數(shù)據(jù)的操作方法也分配到那個對象身上去完成，對象作為這個外部類中的成員變量或方法中的局部變量，每個線程的Runnable對象作為外部類中的成員內(nèi)部類或局部內(nèi)部類。
?總之，要同步互斥的幾段代碼最好是分別放在幾個獨立的方法中，這些方法再放在同一個類中，這樣比較容易實現(xiàn)它們之間的同步互斥和通信。
極端且簡單的方式，即在任意一個類中定義一個static的變量，這將被所有線程共享。
需求:設計4個線程,其中兩個線程每次對j增加1,另外兩個線程對j減少1.
１.使用同一個runnable對象
如果每個線程執(zhí)行的代碼相同,那么可以使用同一個runnable對象,這個runnable有那個共享數(shù)據(jù),例如,賣票系統(tǒng)就是這么做的.
...public static voidmain(String[] args) {
ShareData1 shareData1= newShareData1();newThread(shareData1).start();newThread(shareData1).start();
}static class ShareData1 implementsRunnable {public int count = 100;public voidrun() {
count--;
System.out.println("run:"+count);
}
}
...
2.使用不同的runnable對象
如果每個線程執(zhí)行的代碼不同,那么要使用不同的runnable對象,有如下兩種方式可以實現(xiàn)runnable對象間的數(shù)據(jù)共享
1).實現(xiàn)兩個runnable對象,將共享數(shù)據(jù)分別傳遞給兩個不同線程.
....public static voidmain(String[] args) {final ShareData1 shareData1 = newShareData1();new Thread(newMyRunnable1(shareData1)).start();new Thread(newMyRunnable1(shareData1)).start();
}static class MyRunnable1 implementsRunnable{privateShareData1 shareData1;public voidrun() {
}publicMyRunnable1(ShareData1 shareData1){this.shareData1 =shareData1;
}
}static class MyRunnable2 implementsRunnable{privateShareData1 shareData1;public voidrun() {
}publicMyRunnable2(ShareData1 shareData1){this.shareData1 =shareData1;
}
}static classShareData1 {
....
}
......
2).將這些Runnable對象作為一個內(nèi)部類,將共享數(shù)據(jù)作為成員變量.
public classMultiThreadShareData {private intj;public static voidmain(String[] args) {
MultiThreadShareData multiThreadShareData= newMultiThreadShareData();for(int i=0;i<2;i++){new Thread(multiThreadShareData.new ShareData1()).start();//增加
new Thread(multiThreadShareData.new ShareData2()).start();//減少
}
}//自增
private synchronized voidInc(){
j++;
System.out.println(Thread.currentThread().getName()+" inc "+j);
}//自減
private synchronized voidDec(){
j--;
System.out.println(Thread.currentThread().getName()+" dec "+j);
}class ShareData1 implementsRunnable {public voidrun() {for(int i=0;i<5;i++){
Inc();
}
}
}class ShareData2 implementsRunnable {public voidrun() {for(int i=0;i<5;i++){
Dec();
}
}
}
}
效果:
注:
１.上面的代碼,首先,是定義了一個全局的變量j,即共享數(shù)據(jù);然后,實現(xiàn)Runnable對象,分別去做自增和自減的操作,然后將實現(xiàn)了的Runnable對象作為一個內(nèi)部類塞給新建的線程;最后循環(huán)兩遍,實現(xiàn)兩個自減和兩個自增線程.
２.這里要注意的是之所以將自增和自減提出來,是為了方便進行線程安全控制.
3.方法二和方法一的區(qū)別在于,方法一是主動將共享數(shù)據(jù)賦給Runnable對象,方法二則是將數(shù)據(jù)置為全局變量,然后進行操作.
參考資料：
《多線程》張孝祥視頻
總結
以上是生活随笔為你收集整理的java 多线程 共享数据_JAVA多线程提高四：多个线程之间共享数据的方式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 林桂生（说一说林桂生的简介）
- 下一篇： java kettle log_kett