java中什么叫原子操作?

就是無法被別的線程打斷的操作。要么不執(zhí)行,要么就執(zhí)行成功。例如:x=3是原子操作。過程就是先把工作內(nèi)存的x賦成3,再把主存的x賦成3。y=x不是原子操作,它涉及在工作內(nèi)存先把x值讀出來,再把這個值賦給y。x++或x=x+1也不是原子操作,它涉及取值,自加和賦值。下面我們就用一個例子來說明x ++不是原子操作所帶來的問題。馬克- to-win:馬克 java社區(qū):防盜版實名手機尾號: 73203。


class NumContainer {
    int num;
}
class MulThreMarkToWin extends Thread {
    NumContainer nc;
    public void increase() {
        nc.num++;
    }
    public MulThreMarkToWin(NumContainer nc) {
        this.nc = nc;
    }
    public void run() {
        increase();
    }
}

public class TestMark_to_win {
    public static void main(String[] args) {
        NumContainer nc = new NumContainer();
        MulThreMarkToWin[] threads = new MulThreMarkToWin[10000];
        for (int i = 0; i < 10000; i++) {
            threads[i] = new MulThreMarkToWin(nc);
        }
        for (int i = 0; i < 10000; i++) {
            threads[i].start();
        }
        try {
            Thread.sleep(6000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(nc.num);
    }
}

輸出結(jié)果是:

9997




結(jié)果為什么不是10000?10000個線程都執(zhí)行一遍num++;按理說結(jié)果應(yīng)該是10000?,F(xiàn)在的結(jié)果卻總是小于等于10000。這就要從++操作的非原子性講起。想象在某個時刻,兩個線程同時讀出num值等于30,同時又在自己的工作內(nèi)存做了++操作,之后先后把 31重新寫回主存。這樣結(jié)果就小于10000了。順便說一句,這種情況即使加了volatile關(guān)鍵字,也解決不了問題。有volatile也照樣覆蓋,因為volatile只能保證讀時是最新的。但他解決不了原子問題。像剛才這樣,該覆蓋時照樣覆蓋。那怎么解決呢?只有通過原子操作。

import java.util.concurrent.atomic.AtomicInteger;

class MulThreMarkToWin extends Thread {
    private AtomicInteger inc;
    public void increase() {
        inc.getAndIncrement();
    }
    public MulThreMarkToWin(AtomicInteger inc) {
        this.inc = inc;
    }
    public void run() {
        increase();
    }
}

public class TestMark_to_win {
    public static void main(String[] args){
        AtomicInteger inc = new AtomicInteger();
        MulThreMarkToWin[] threads = new MulThreMarkToWin[10000];
        for (int i = 0; i < 10000;i++) {
            threads[i] = new MulThreMarkToWin(inc);
        }
        for (int i = 0; i < 10000;i++) {
            threads[i].start();
        }
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(inc);
    }
}

輸出結(jié)果是:
10000