java并发:原子类之AtomicLong

原子类之AtomicLong

java线程中的操作，需要满足原子性、可见性等原则，比如i++这样的操作不具备原子性，
A线程读取了i，另一个线程执行i++,A线程再执行i++就会引发线程安全问题

一个非原子性的自加引发的安全例子

下面的例子执行1000个线程，有意思的还Long自加比Interger更容易发现结果是比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满足原子性主要是实现了CAS

比较并交换(compare and swap, CAS)，是原子操作的一种，可用于在多线程编程中实现不被打断的数据交换操作，从而避免多线程同时改写某一数据时由于执行顺序不确定性以及中断的不可预知性产生的数据不一致问题。 该操作通过将内存中的值与指定数据进行比较，当数值一样时将内存中的数据替换为新的值。

使用使用AtomicLong，1000个线程执行之后返回的结果是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;
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问题