在Java多线程中,i++和i--是非线程安全的。
例子:
public class PlusPlusTest {
public static void main(String[] args) throws InterruptedException {
Num num = new Num();
ThreadA threadA = new ThreadA(num);
ThreadB threadB = new ThreadB(num);
threadA.start();
threadB.start();
Thread.sleep(200);
System.out.println(num.count);
}
}
class ThreadA extends Thread {
private Num num;
public ThreadA(Num num) {
this.num = num;
}
@Override
public void run() {
for (int i = 0; i < 1000; i++) {
num.count++;
}
}
}
class ThreadB extends Thread {
private Num num;
public ThreadB(Num num) {
this.num = num;
}
@Override
public void run() {
for (int i = 0; i < 1000; i++) {
num.count++;
}
}
}
class Num {
int count = 0;
public Num() {
}
}
以上代码输出结果基本上不是2000,会比2000小。
原因:
在线程A中,i++的过程为:
temp1 = i; temp2 = temp1 + 1; i = temp2;
在线程B中,i++的过程为:
temp3 = i; temp4 = temp3 + 1; i = temp4;
在i=0的时候,线程A和B同时读取i=0。
线程A执行++后,i被修改成1。
线程B执行++后,i被修改,但还是1。
问:这样的解释对么?
想到把count变量申明为volatile,但是:
即使把count申明为volatile,输出的结果也不是2000,请问为什么?
class Num {
volatile int count = 0;
public Num() {
}
}
最后
把count变量包装成AtomicInteger之后,输出的结果为2000,正确,这又是为什么?
因為
volatile
不保证操作的原子性,i++
這種操作並不是原子操作。其實不是很妥當,
i++
的操作應該沒有那麼麻煩,讀值是指讀到CPU。出現錯誤,執行順序如下:
线程1
读到i
的值为0
,线程2
也读到i
的值为0
,线程1
执行了+1
操作,将结果值1
寫入到內存,线程2
执行了+1
操作,将结果值1
寫入到記憶體。volatile
只能保证可见性,就是说实时读到i
的最新值,但不能保證原子性,即上述執行順序完全允許出現。這也可以參考我對這個問題的回答:https://segmentfault.com/q/10...AtomicInteger
是原子的int
,这个是由Java
實現的,大概理解下源碼:重點是
compareAndSet()
,這個方法會判斷current
與i
的值是否符合條件:此時i的值是否和current相等
,滿足條件了直接退出循環,不然再++
一遍,直到正常。compareAndSet()
,这个方法会判断current
与i
的值是否满足条件:此时i的值是否和current相等
,满足条件了直接退出循环,不然再++
一遍,直到正常。compareAndSet方法
是由Java的unsafe
实现的,这个应该很底层了,都是native
方法,我也没研究过。不过,一般程序员是不会接触到unsafe
compareAndSet方法
是由Java的unsafe
實現的,這個應該很底層了,都是native
方法,我也沒研究過。不過,一般程式設計師是不會接觸到unsafe
程式設計的。volatile只能保證可見性,即別人修改了之後你立刻能讀到,但是你改的時候別人也可以改。
AtomicInteger是基於CAS(Compare And Swap)的。
懶的寫答案了,給一個非常好的文章Java並發程式設計:volatile關鍵字解析
volatile保證每次得到的資料是最新的(從記憶體中讀取),i++; --> i=i+1; 如果執行到i+1沒有賦值給i的話,就無法保證另一個執行緒得到的數據是最新的,後面那個是原子操作,所以能夠保證i=這一定會執行