您當前位置：首頁 > php開源 > php教程 > 【java并發】多個線程間共享數據

【java并發】多個線程間共享數據

來源：程序員人生發布時間：2016-06-15 14:32:59 閱讀次數：2447次

先看1個多線程間同享數據的問題：

設計4個線程，其中兩個線程每次對data增加1，另外兩個線程每次對data減少1。

　　從問題來看，很明顯觸及到了線程間通數據的同享，4個線程同享1個data，共同操作1個data。我們先把上面這個問題放在1邊，漸漸分析多個線程之間同享數據的1些情況，從最簡單開始，分類分析完了后，到時候也好解決上面這個問題了。

1. 每一個線程履行的任務相同

　　這是最簡單的1種情況，比如賣票，幾個線程共同操作記錄票數的那個變量，任務都是使它減1。針對這類情況，我們只需要寫1個類實現Runnable接口便可，在run()方法中對這個票進行減1，然后將這個Runnalbe扔給多個線程去履行，自然它們就操作同1個data了?？?下代碼：

public class MultiThreadShareData {

    public static void main(String[] args) {

        ShareData task = new ShareData(); //1個類實現了Runnable接口

        for(int i = 0; i < 4; i ++) {   //4個線程來賣票       
            new Thread(task).start();
        }

    }

}

class ShareData implements Runnable {

    private int data = 100;
    @Override
    public void run() { //賣票，每次1個線程進來，先判斷票數是不是大于0
//      while(data > 0) {
            synchronized(this) {
                if(data > 0) {
                    System.out.println(Thread.currentThread().getName() + ": " + data);
                    data--;
                }
            }
//      }
    }
}

　　這很好理解，也很容易實現，4個線程賣了4張票。運行結果為：

Thread-0: 100
Thread⑶: 99
Thread⑵: 98
Thread⑴: 97

2. 每一個線程履行不同的任務

　　就如上面那個題目所描寫的，兩個線程履行data增，兩個線程履行data減。針對這類情況，我們要實現兩個Runnable了，由于很明顯有兩個不同的任務了，1個任務履行data增，另外一個任務履行data減。為了便于保護，可以將兩個任務方法放到1個類中，然后將data也放在這個類中，然后傳到不同的Runnable中，便可完成數據的同享。以下：

public class MultiThreadShareData {

    public static void main(String[] args) {

        ShareData task = new ShareData(); //公共數據和任務放在task中

        for(int i = 0; i < 2; i ++) { //開啟兩個線程增加data

            new Thread(new Runnable() {

                @Override
                public void run() {
                    task.increment();
                }
            }).start();
        }

        for(int i = 0; i < 2; i ++) { //開啟兩個線程減少data

            new Thread(new Runnable() {

                @Override
                public void run() {
                    task.decrement();
                }
            }).start();
        }           
    }
}   


class ShareData /*implements Runnable*/ {

    private int data = 0;
    public synchronized void increment() { //增加data
        System.out.println(Thread.currentThread().getName() + ": before : " + data);
        data++;
        System.out.println(Thread.currentThread().getName() + ": after : " + data);
    }

    public synchronized void decrement() { //減少data
        System.out.println(Thread.currentThread().getName() + ": before : " + data);
        data--;
        System.out.println(Thread.currentThread().getName() + ": after : " + data);
    }
}

　　看1下打印結果：

Thread-0: before : 0
Thread-0: after : 1
Thread⑴: before : 1
Thread⑴: after : 2
Thread⑵: before : 2
Thread⑵: after : 1
Thread⑶: before : 1
Thread⑶: after : 0

　　這樣寫的好處是兩個任務方法可以直接在方法名上進行同步操作，這類模式的好處在前面的博文中已有說過了，封裝的好。
　　最后總結1下，多個線程之間同享數據主要關注兩點就行：1是甚么任務？幾個任務？2是幾個線程？記住 1點：幾個任務和幾個線程是沒有關系的！100個線程可以履行1個任務，也能夠履行2個任務，3個任務……
　　如果只有1個任務，那說明多個線程履行1個任務，我們只要實現1個Runnable接口，把公共data放進Runnable，把任務放進去run()中便可（任務注意要同步），然后開啟N個線程去履行這個任務便可；如果有M個任務，那我們新建1個專門履行任務的類，把公共的data放進類中，把任務作為類中的同步方法便可，然后開啟N個線程，每一個線程中扔1個Runnable，依照要求履行任務類中的方法便可。
　　到這里，終究能體會到任務和線程的分離了，這類思想也算是面向對象的1種吧，之前學習的時候沒啥感覺，現在越總結感覺思路越清晰。

　　相干瀏覽：http://blog.csdn.net/column/details/bingfa.html

—–樂于分享，共同進步！
—–更多文章請看：http://blog.csdn.net/eson_15

生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈
程序員人生