java核心知識點學習----多線程間的數據共享的幾種實現方式比較

需求:設計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對象作為一個內部類,將共享數據作為成員變量.

這里用這個方法解決上面的需求,請看下面代碼:

package com.amos.concurrent;

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對象,方法二則是將數據置為全局變量,然后進行操作.