JAVA多線程學習八-多個線程之間共享數據的方式

多個線程訪問共享對象和數據的方式

如果每個線程執行的代碼相同，可以使用同一個Runnable對象，這個Runnable對象中有那個共享數據，例如，買票系統就可以這么做。 

如果每個線程執行的代碼不同，這時候需要用不同的Runnable對象，有如下兩種方式來實現這些Runnable對象之間的數據共享： 

Ø將共享數據封裝在另外一個對象中，然后將這個對象逐一傳遞給各個Runnable對象。每個線程對共享數據的操作方法也分配到那個對象身上去完成，這樣容易實現針對該數據進行的各個操作的互斥和通信。

Ø將這些Runnable對象作為某一個類中的內部類，共享數據作為這個外部類中的成員變量，每個線程對共享數據的操作方法也分配給外部類，以便實現對共享數據進行的各個操作的互斥和通信，作為內部類的各個Runnable對象調用外部類的這些方法。 

Ø上面兩種方式的組合：將共享數據封裝在另外一個對象中，每個線程對共享數據的操作方法也分配到那個對象身上去完成，對象作為這個外部類中的成員變量或方法中的局部變量，每個線程的Runnable對象作為外部類中的成員內部類或局部內部類。

Ø總之，要同步互斥的幾段代碼最好是分別放在幾個獨立的方法中，這些方法再放在同一個類中，這樣比較容易實現它們之間的同步互斥和通信。

極端且簡單的方式，即在任意一個類中定義一個static的變量，這將被所有線程共享。

 

需求:設計4個線程,其中兩個線程每次對j增加1,另外兩個線程對j減少1.

１.使用同一個runnable對象

如果每個線程執行的代碼相同,那么可以使用同一個runnable對象,這個runnable有那個共享數據,例如,賣票系統就是這么做的.

...
    public static void main(String[] args) {
        ShareData1 shareData1 = new ShareData1();
        new Thread(shareData1).start();
        new Thread(shareData1).start();
    }

    static class ShareData1 implements Runnable {
        public int count = 100;
        public void run() {
            count--;
            System.out.println("run:"+count);
        }
    }

...

2.使用不同的runnable對象

如果每個線程執行的代碼不同,那么要使用不同的runnable對象,有如下兩種方式可以實現runnable對象間的數據共享

1).實現兩個runnable對象,將共享數據分別傳遞給兩個不同線程.

....
public static void main(String[] args) {
        final ShareData1 shareData1 = new ShareData1();
        new Thread(new MyRunnable1(shareData1)).start();
        new Thread(new MyRunnable1(shareData1)).start();
}
static class MyRunnable1 implements Runnable{
        private ShareData1 shareData1;
        public void run() {
        }
        public MyRunnable1(ShareData1 shareData1){
            this.shareData1 = shareData1;
        }
    }
static class MyRunnable2 implements Runnable{
        private ShareData1 shareData1;
        public void run() {
        }
        public MyRunnable2(ShareData1 shareData1){
            this.shareData1 = shareData1;
        }
    }
static class ShareData1 {
....
}
......

2).將這些Runnable對象作為一個內部類,將共享數據作為成員變量.

public class MultiThreadShareData {
    private int j;
    public static void main(String[] args) {
        MultiThreadShareData multiThreadShareData = new MultiThreadShareData();
        for(int i=0;i<2;i++){
            new Thread(multiThreadShareData.new ShareData1()).start();//增加
            new Thread(multiThreadShareData.new ShareData2()).start();//減少
        }
    }
    //自增
    private synchronized void Inc(){
        j++;
        System.out.println(Thread.currentThread().getName()+" inc "+j);
    }
    //自減
    private synchronized void Dec(){
        j--;
        System.out.println(Thread.currentThread().getName()+" dec "+j);
    }
    
    class ShareData1 implements Runnable {
        public void run() {
            for(int i=0;i<5;i++){
                Inc();
            }
        }
    }
    class ShareData2 implements Runnable {
        public void run() {
            for(int i=0;i<5;i++){
                Dec();
            }
        }
    }
}

效果:

注:

１.上面的代碼,首先,是定義了一個全局的變量j,即共享數據;然后,實現Runnable對象,分別去做自增和自減的操作,然后將實現了的Runnable對象作為一個內部類塞給新建的線程;最后循環兩遍,實現兩個自減和兩個自增線程.

２.這里要注意的是之所以將自增和自減提出來,是為了方便進行線程安全控制.

3.方法二和方法一的區別在於,方法一是主動將共享數據賦給Runnable對象,方法二則是將數據置為全局變量,然后進行操作.