java 多线程 共享数据_JAVA多线程提高四：多个线程之间共享数据的方式
多個(gè)線程訪問(wèn)共享對(duì)象和數(shù)據(jù)的方式
如果每個(gè)線程執(zhí)行的代碼相同，可以使用同一個(gè)Runnable對(duì)象，這個(gè)Runnable對(duì)象中有那個(gè)共享數(shù)據(jù)，例如，買(mǎi)票系統(tǒng)就可以這么做。
如果每個(gè)線程執(zhí)行的代碼不同，這時(shí)候需要用不同的Runnable對(duì)象，有如下兩種方式來(lái)實(shí)現(xiàn)這些Runnable對(duì)象之間的數(shù)據(jù)共享：
?將共享數(shù)據(jù)封裝在另外一個(gè)對(duì)象中，然后將這個(gè)對(duì)象逐一傳遞給各個(gè)Runnable對(duì)象。每個(gè)線程對(duì)共享數(shù)據(jù)的操作方法也分配到那個(gè)對(duì)象身上去完成，這樣容易實(shí)現(xiàn)針對(duì)該數(shù)據(jù)進(jìn)行的各個(gè)操作的互斥和通信。
?將這些Runnable對(duì)象作為某一個(gè)類(lèi)中的內(nèi)部類(lèi)，共享數(shù)據(jù)作為這個(gè)外部類(lèi)中的成員變量，每個(gè)線程對(duì)共享數(shù)據(jù)的操作方法也分配給外部類(lèi)，以便實(shí)現(xiàn)對(duì)共享數(shù)據(jù)進(jìn)行的各個(gè)操作的互斥和通信，作為內(nèi)部類(lèi)的各個(gè)Runnable對(duì)象調(diào)用外部類(lèi)的這些方法。
?上面兩種方式的組合：將共享數(shù)據(jù)封裝在另外一個(gè)對(duì)象中，每個(gè)線程對(duì)共享數(shù)據(jù)的操作方法也分配到那個(gè)對(duì)象身上去完成，對(duì)象作為這個(gè)外部類(lèi)中的成員變量或方法中的局部變量，每個(gè)線程的Runnable對(duì)象作為外部類(lèi)中的成員內(nèi)部類(lèi)或局部?jī)?nèi)部類(lèi)。
?總之，要同步互斥的幾段代碼最好是分別放在幾個(gè)獨(dú)立的方法中，這些方法再放在同一個(gè)類(lèi)中，這樣比較容易實(shí)現(xiàn)它們之間的同步互斥和通信。
極端且簡(jiǎn)單的方式，即在任意一個(gè)類(lèi)中定義一個(gè)static的變量，這將被所有線程共享。
需求:設(shè)計(jì)4個(gè)線程,其中兩個(gè)線程每次對(duì)j增加1,另外兩個(gè)線程對(duì)j減少1.
１.使用同一個(gè)runnable對(duì)象
如果每個(gè)線程執(zhí)行的代碼相同,那么可以使用同一個(gè)runnable對(duì)象,這個(gè)runnable有那個(gè)共享數(shù)據(jù),例如,賣(mài)票系統(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對(duì)象
如果每個(gè)線程執(zhí)行的代碼不同,那么要使用不同的runnable對(duì)象,有如下兩種方式可以實(shí)現(xiàn)runnable對(duì)象間的數(shù)據(jù)共享
1).實(shí)現(xiàn)兩個(gè)runnable對(duì)象,將共享數(shù)據(jù)分別傳遞給兩個(gè)不同線程.
....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對(duì)象作為一個(gè)內(nèi)部類(lè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();
}
}
}
}
效果:
注:
１.上面的代碼,首先,是定義了一個(gè)全局的變量j,即共享數(shù)據(jù);然后,實(shí)現(xiàn)Runnable對(duì)象,分別去做自增和自減的操作,然后將實(shí)現(xiàn)了的Runnable對(duì)象作為一個(gè)內(nèi)部類(lèi)塞給新建的線程;最后循環(huán)兩遍,實(shí)現(xiàn)兩個(gè)自減和兩個(gè)自增線程.
２.這里要注意的是之所以將自增和自減提出來(lái),是為了方便進(jìn)行線程安全控制.
3.方法二和方法一的區(qū)別在于,方法一是主動(dòng)將共享數(shù)據(jù)賦給Runnable對(duì)象,方法二則是將數(shù)據(jù)置為全局變量,然后進(jìn)行操作.
參考資料：
《多線程》張孝祥視頻
總結(jié)
以上是生活随笔為你收集整理的java 多线程 共享数据_JAVA多线程提高四：多个线程之间共享数据的方式的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 林桂生（说一说林桂生的简介）
- 下一篇： java kettle log_kett