Concurrent初探 --- Atomic 无锁

时间:2021-09-15 12:09:21

一.CAS算法

  Compare And Swap,CAS算法的过程是这样:它包含3个参数CAS(V,E,N)。V表示要更新的变量,E表示预期值,N表示新值。仅当V值等于E值时,才会将V的值设为N,如果V值和E值不同,则说明已经有其他线程做了更新,则当前线程什么都不做。最后,CAS返回当前V的真实值。CAS操作是抱着乐观的态度进行的,它总是认为自己可以成功完成操作。当多个线程同时使用CAS操作一个变量时,只有一个会胜出,并成功更新,其余均会失败。失败的线程不会被挂起,仅是被告知失败,并且允许再次尝试,当然也允许失败的线程放弃操作。基于这样的原理,CAS操作即时没有锁,也可以发现其他线程对当前线程的干扰,并进行恰当的处理。

 

二.Unsafe类(实现无锁的关键类):

  unsafe提供一些类似于C++的指针操作.非安全的操作,比如:根据偏移量设置值park()     底层的CAS操作非公开API,在不同版本的JDK中, 可能有较大差异

  主要接口:    

  //获得给定对象偏移量上的int值
  public native int getInt(Object o, long offset);
  //设置给定对象偏移量上的int值
  public native void putInt(Object o, long offset, int x);
  //获得字段在对象中的偏移量
  public native long objectFieldOffset(Field f);
  //设置给定对象的int值,使用volatile语义
  public native void putIntVolatile(Object o, long offset, int x);
  //获得给定对象对象的int值,使用volatile语义
  public native int getIntVolatile(Object o, long offset);
  //和putIntVolatile()一样,但是它要求被操作字段就是volatile类型的
  public native void putOrderedInt(Object o, long offset, int x);

  

三.无锁类:

 

  1.AtomicInteger:

    API:

      public final int get() //取得当前值

      public final void set(int newValue) //设置当前值

      public final int getAndSet(int newValue) //设置新值,并返回旧值

      public final boolean compareAndSet(int expect, int u)//如果当前值为expect,则设置为u

      public final int getAndIncrement() //当前值加1,返回旧值
      public final int getAndDecrement() //当前值减1,返回旧值
      public final int getAndAdd(int delta) //当前值增加delta,返回旧值
      public final int incrementAndGet() //当前值加1,返回新值
      public final int decrementAndGet() //当前值减1,返回新值
      public final int addAndGet(int delta) //当前值增加delta,返回新值