原子類之AtomicLong

java線程中的操作，需要滿足原子性、可見性等原則，比如i++這樣的操作不具備原子性，

A線程讀取了i，另一個線程執(zhí)行i++,A線程再執(zhí)行i++就會引發(fā)線程安全問題

推薦學(xué)習(xí)的AtomicInteger和AtomicLong博客

一個非原子性的自加引發(fā)的安全例子

下面的例子執(zhí)行1000個線程，有意思的還Long自加比Interger更容易發(fā)現(xiàn)結(jié)果是比1000小。

package com.java.javabase.thread.base.concurrent.atomic;

import lombok.Data;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

@Slf4j

public class AtomicLongtest {

public static void main(String[] args) {

AtomicLongtest test =new AtomicLongtest();

Count count =test.new Count();

ExecutorService service = Executors.newCachedThreadPool();

for(int i=0;i<1000;i++){

service.execute(()->count.increace());

}

service.shutdown();

try {

service.awaitTermination(1, TimeUnit.DAYS);

} catch (InterruptedException e) {

e.printStackTrace();

}

log.info("End count :{}",count.getCount());

}

@Data

class Count{

private Long count=0L;

public void increace(){

log.info("count {}",count++);

}

}

}

通過syncronized方法

通過syncronized方法使得自加操作安全

使用AtomicLong滿足原子性

使用AtomicLong滿足原子性主要是實現(xiàn)了CAS

比較并交換(compare and swap, CAS)，是原子操作的一種，可用于在多線程編程中實現(xiàn)不被打斷的數(shù)據(jù)交換操作，從而避免多線程同時改寫某一數(shù)據(jù)時由于執(zhí)行順序不確定性以及中斷的不可預(yù)知性產(chǎn)生的數(shù)據(jù)不一致問題。 該操作通過將內(nèi)存中的值與指定數(shù)據(jù)進行比較，當(dāng)數(shù)值一樣時將內(nèi)存中的數(shù)據(jù)替換為新的值。

使用使用AtomicLong，1000個線程執(zhí)行之后返回的結(jié)果是1000，保證了結(jié)果的正確

package com.java.javabase.thread.base.concurrent.atomic;

import lombok.Data;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicLong;

@Slf4j

public class AtomicLongTest2 {

public static void main(String[] args) {

AtomicLongTest2 test =new AtomicLongTest2();

Count count =test.new Count();

ExecutorService service = Executors.newCachedThreadPool();

for(int i=0;i<1000;i++){

service.execute(()->count.increace());

}

service.shutdown();

try {

service.awaitTermination(1, TimeUnit.DAYS);

} catch (InterruptedException e) {

e.printStackTrace();

}

log.info("End count :{}",count.getCount());

}

@Data

class Count{

private AtomicLong count=new AtomicLong(0);

public void increace(){

log.info("count {}",count.incrementAndGet());

}

}

}

AtomicLong的ABA問題

CAS有一個問題是ABA問題：

1.ABC三個線程

2.count=10,這時AB線程的內(nèi)存值和預(yù)期值都是10

3.B線程把count修改100成功后，內(nèi)存值是100

4.A線程又把count設(shè)置為10

5.這個時候內(nèi)存值和預(yù)期值都是10

6.c線程是不知道A和B對count做了什么操作的

總結(jié)

以上是生活随笔為你收集整理的java atomiclong 使用_java并发:原子类之AtomicLong的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。