欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java concurrency之AtomicLongFieldUpdater原子類_動力節(jié)點Java學院整理

 更新時間:2017年06月06日 10:29:32   投稿:mrr  
AtomicLongFieldUpdater可以對指定"類的 'volatile long'類型的成員"進行原子更新。它是基于反射原理實現(xiàn)的。下面通過本文給大家分享Java concurrency之AtomicLongFieldUpdater原子類的相關知識,感興趣的朋友一起看看吧

AtomicLongFieldUpdater介紹和函數(shù)列表

AtomicLongFieldUpdater可以對指定"類的 'volatile long'類型的成員"進行原子更新。它是基于反射原理實現(xiàn)的。

AtomicLongFieldUpdater函數(shù)列表

// 受保護的無操作構造方法,供子類使用。
protected AtomicLongFieldUpdater()
// 以原子方式將給定值添加到此更新器管理的給定對象的字段的當前值。
long addAndGet(T obj, long delta)
// 如果當前值 == 預期值,則以原子方式將此更新器所管理的給定對象的字段設置為給定的更新值。
abstract boolean compareAndSet(T obj, long expect, long update)
// 以原子方式將此更新器管理的給定對象字段當前值減 1。
long decrementAndGet(T obj)
// 獲取此更新器管理的在給定對象的字段中保持的當前值。
abstract long get(T obj)
// 以原子方式將給定值添加到此更新器管理的給定對象的字段的當前值。
long getAndAdd(T obj, long delta)
// 以原子方式將此更新器管理的給定對象字段當前值減 1。
long getAndDecrement(T obj)
// 以原子方式將此更新器管理的給定對象字段的當前值加 1。
long getAndIncrement(T obj)
// 將此更新器管理的給定對象的字段以原子方式設置為給定值,并返回舊值。
long getAndSet(T obj, long newValue)
// 以原子方式將此更新器管理的給定對象字段當前值加 1。
long incrementAndGet(T obj)
// 最后將此更新器管理的給定對象的字段設置為給定更新值。
abstract void lazySet(T obj, long newValue)
// 為對象創(chuàng)建并返回一個具有給定字段的更新器。
static <U> AtomicLongFieldUpdater<U> newUpdater(Class<U> tclass, String fieldName)
// 將此更新器管理的給定對象的字段設置為給定更新值。
abstract void set(T obj, long newValue)
// 如果當前值 == 預期值,則以原子方式將此更新器所管理的給定對象的字段設置為給定的更新值。
abstract boolean weakCompareAndSet(T obj, long expect, long update)

AtomicLongFieldUpdater示例

// LongTest.java的源碼
import java.util.concurrent.atomic.AtomicLongFieldUpdater;
public class LongFieldTest {
  public static void main(String[] args) {
    // 獲取Person的class對象
    Class cls = Person.class; 
    // 新建AtomicLongFieldUpdater對象,傳遞參數(shù)是“class對象”和“l(fā)ong類型在類中對應的名稱”
    AtomicLongFieldUpdater mAtoLong = AtomicLongFieldUpdater.newUpdater(cls, "id");
    Person person = new Person(12345678L);
    // 比較person的"id"屬性,如果id的值為12345678L,則設置為1000。
    mAtoLong.compareAndSet(person, 12345678L, 1000);
    System.out.println("id="+person.getId());
  }
}
class Person {
  volatile long id;
  public Person(long id) {
    this.id = id;
  }
  public void setId(long id) {
    this.id = id;
  }
  public long getId() {
    return id;
  }
}

運行結(jié)果:

id=1000

AtomicLongFieldUpdater源碼分析(基于JDK1.7.0_40)

AtomicLongFieldUpdater完整源碼

 /*
  * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  *
  */
 /*
  *
  *
  *
  *
  *
  * Written by Doug Lea with assistance from members of JCP JSR-
  * Expert Group and released to the public domain, as explained at
  * http://creativecommons.org/publicdomain/zero/./
  */
 package java.util.concurrent.atomic;
 import java.lang.reflect.*;
 import sun.misc.Unsafe;
 import sun.reflect.CallerSensitive;
 import sun.reflect.Reflection;
 /**
  * A reflection-based utility that enables atomic updates to
  * designated {@code volatile} reference fields of designated
  * classes. This class is designed for use in atomic data structures
  * in which several reference fields of the same node are
  * independently subject to atomic updates. For example, a tree node
  * might be declared as
  *
  * <pre> {@code
  * class Node {
  *  private volatile Node left, right;
  *
  *  private static final AtomicReferenceFieldUpdater<Node, Node> leftUpdater =
  *   AtomicReferenceFieldUpdater.newUpdater(Node.class, Node.class, "left");
  *  private static AtomicReferenceFieldUpdater<Node, Node> rightUpdater =
  *   AtomicReferenceFieldUpdater.newUpdater(Node.class, Node.class, "right");
  *
  *  Node getLeft() { return left; }
  *  boolean compareAndSetLeft(Node expect, Node update) {
  *   return leftUpdater.compareAndSet(this, expect, update);
  *  }
  *  // ... and so on
  * }}</pre>
  *
  * <p>Note that the guarantees of the {@code compareAndSet}
  * method in this class are weaker than in other atomic classes.
  * Because this class cannot ensure that all uses of the field
  * are appropriate for purposes of atomic access, it can
  * guarantee atomicity only with respect to other invocations of
  * {@code compareAndSet} and {@code set} on the same updater.
  *
  * @since .
  * @author Doug Lea
  * @param <T> The type of the object holding the updatable field
  * @param <V> The type of the field
  */
 public abstract class AtomicReferenceFieldUpdater<T, V> {
   /**
    * Creates and returns an updater for objects with the given field.
    * The Class arguments are needed to check that reflective types and
    * generic types match.
    *
    * @param tclass the class of the objects holding the field.
    * @param vclass the class of the field
    * @param fieldName the name of the field to be updated.
    * @return the updater
    * @throws IllegalArgumentException if the field is not a volatile reference type.
    * @throws RuntimeException with a nested reflection-based
    * exception if the class does not hold field or is the wrong type.
    */
   @CallerSensitive
   public static <U, W> AtomicReferenceFieldUpdater<U,W> newUpdater(Class<U> tclass, Class<W> vclass, String fieldName) {
     return new AtomicReferenceFieldUpdaterImpl<U,W>(tclass,
                             vclass,
                             fieldName,
                             Reflection.getCallerClass());
   }
   /**
   * Protected do-nothing constructor for use by subclasses.
   */
   protected AtomicReferenceFieldUpdater() {
   }
   /**
   * Atomically sets the field of the given object managed by this updater
   * to the given updated value if the current value {@code ==} the
   * expected value. This method is guaranteed to be atomic with respect to
   * other calls to {@code compareAndSet} and {@code set}, but not
   * necessarily with respect to other changes in the field.
   *
   * @param obj An object whose field to conditionally set
   * @param expect the expected value
   * @param update the new value
   * @return true if successful.
   */
   public abstract boolean compareAndSet(T obj, V expect, V update);
   /**
   * Atomically sets the field of the given object managed by this updater
   * to the given updated value if the current value {@code ==} the
   * expected value. This method is guaranteed to be atomic with respect to
   * other calls to {@code compareAndSet} and {@code set}, but not
   * necessarily with respect to other changes in the field.
   *
   * <p>May <a href="package-summary.html#Spurious" rel="external nofollow" >fail spuriously</a>
   * and does not provide ordering guarantees, so is only rarely an
   * appropriate alternative to {@code compareAndSet}.
   *
   * @param obj An object whose field to conditionally set
   * @param expect the expected value
   * @param update the new value
   * @return true if successful.
   */
   public abstract boolean weakCompareAndSet(T obj, V expect, V update);
   /**
   * Sets the field of the given object managed by this updater to the
   * given updated value. This operation is guaranteed to act as a volatile
   * store with respect to subsequent invocations of {@code compareAndSet}.
   *
   * @param obj An object whose field to set
   * @param newValue the new value
   */
   public abstract void set(T obj, V newValue);
   /**
   * Eventually sets the field of the given object managed by this
   * updater to the given updated value.
   *
   * @param obj An object whose field to set
   * @param newValue the new value
   * @since 1.6
   */
   public abstract void lazySet(T obj, V newValue);
   /**
   * Gets the current value held in the field of the given object managed
   * by this updater.
   *
   * @param obj An object whose field to get
   * @return the current value
   */
   public abstract V get(T obj);
   /**
   * Atomically sets the field of the given object managed by this updater
   * to the given value and returns the old value.
   *
   * @param obj An object whose field to get and set
   * @param newValue the new value
   * @return the previous value
   */
   public V getAndSet(T obj, V newValue) {
     for (;;) {
       V current = get(obj);
       if (compareAndSet(obj, current, newValue))
         return current;
     }
   }
   private static final class AtomicReferenceFieldUpdaterImpl<T,V>
     extends AtomicReferenceFieldUpdater<T,V> {
     private static final Unsafe unsafe = Unsafe.getUnsafe();
     private final long offset;
     private final Class<T> tclass;
     private final Class<V> vclass;
     private final Class cclass;
     /*
     * Internal type checks within all update methods contain
     * internal inlined optimizations checking for the common
     * cases where the class is final (in which case a simple
     * getClass comparison suffices) or is of type Object (in
     * which case no check is needed because all objects are
     * instances of Object). The Object case is handled simply by
     * setting vclass to null in constructor. The targetCheck and
     * updateCheck methods are invoked when these faster
     * screenings fail.
     */
     AtomicReferenceFieldUpdaterImpl(Class<T> tclass,
                     Class<V> vclass,
                     String fieldName,
                     Class<?> caller) {
       Field field = null;
       Class fieldClass = null;
       int modifiers = 0;
       try {
         field = tclass.getDeclaredField(fieldName);
         modifiers = field.getModifiers();
         sun.reflect.misc.ReflectUtil.ensureMemberAccess(
           caller, tclass, null, modifiers);
         sun.reflect.misc.ReflectUtil.checkPackageAccess(tclass);
         fieldClass = field.getType();
       } catch (Exception ex) {
         throw new RuntimeException(ex);
       }
       if (vclass != fieldClass)
         throw new ClassCastException();
       if (!Modifier.isVolatile(modifiers))
         throw new IllegalArgumentException("Must be volatile type");
       this.cclass = (Modifier.isProtected(modifiers) &&
              caller != tclass) ? caller : null;
       this.tclass = tclass;
       if (vclass == Object.class)
         this.vclass = null;
       else
         this.vclass = vclass;
       offset = unsafe.objectFieldOffset(field);
     }
     void targetCheck(T obj) {
       if (!tclass.isInstance(obj))
         throw new ClassCastException();
       if (cclass != null)
         ensureProtectedAccess(obj);
     }
     void updateCheck(T obj, V update) {
       if (!tclass.isInstance(obj) ||
         (update != null && vclass != null && !vclass.isInstance(update)))
         throw new ClassCastException();
       if (cclass != null)
         ensureProtectedAccess(obj);
     }
     public boolean compareAndSet(T obj, V expect, V update) {
       if (obj == null || obj.getClass() != tclass || cclass != null ||
         (update != null && vclass != null &&
         vclass != update.getClass()))
         updateCheck(obj, update);
       return unsafe.compareAndSwapObject(obj, offset, expect, update);
     }
     public boolean weakCompareAndSet(T obj, V expect, V update) {
       // same implementation as strong form for now
       if (obj == null || obj.getClass() != tclass || cclass != null ||
         (update != null && vclass != null &&
         vclass != update.getClass()))
         updateCheck(obj, update);
       return unsafe.compareAndSwapObject(obj, offset, expect, update);
     }
     public void set(T obj, V newValue) {
       if (obj == null || obj.getClass() != tclass || cclass != null ||
         (newValue != null && vclass != null &&
         vclass != newValue.getClass()))
         updateCheck(obj, newValue);
       unsafe.putObjectVolatile(obj, offset, newValue);
     }
     public void lazySet(T obj, V newValue) {
       if (obj == null || obj.getClass() != tclass || cclass != null ||
         (newValue != null && vclass != null &&
         vclass != newValue.getClass()))
         updateCheck(obj, newValue);
       unsafe.putOrderedObject(obj, offset, newValue);
     }
     public V get(T obj) {
       if (obj == null || obj.getClass() != tclass || cclass != null)
         targetCheck(obj);
       return (V)unsafe.getObjectVolatile(obj, offset);
     }
     private void ensureProtectedAccess(T obj) {
       if (cclass.isInstance(obj)) {
         return;
       }
       throw new RuntimeException(
         new IllegalAccessException("Class " +
           cclass.getName() +
           " can not access a protected member of class " +
           tclass.getName() +
           " using an instance of " +
           obj.getClass().getName()
         )
       );
     }
   }
 }

   下面分析LongFieldTest.java的流程。

1. newUpdater()

newUpdater()的源碼如下:

public static <U> AtomicLongFieldUpdater<U> newUpdater(Class<U> tclass, String fieldName) {
  Class<?> caller = Reflection.getCallerClass();
  if (AtomicLong.VM_SUPPORTS_LONG_CAS)
    return new CASUpdater<U>(tclass, fieldName, caller);
  else
    return new LockedUpdater<U>(tclass, fieldName, caller);
}

說明:newUpdater()的作用是獲取一個AtomicIntegerFieldUpdater類型的對象。

它實際上返回的是CASUpdater對象,或者LockedUpdater對象;具體返回哪一個類取決于JVM是否支持long類型的CAS函數(shù)。CASUpdater和LockedUpdater都是AtomicIntegerFieldUpdater的子類,它們的實現(xiàn)類似。下面以CASUpdater來進行說明。 

CASUpdater類的源碼如下:

public boolean compareAndSet(T obj, long expect, long update) {
  if (obj == null || obj.getClass() != tclass || cclass != null) fullCheck(obj);
  return unsafe.compareAndSwapLong(obj, offset, expect, update);
}

說明:它實際上是通過CAS函數(shù)操作。如果類的long對象的值是expect,則設置它的值為update。 

相關文章

  • Spring?Data?JPA框架的Repository自定義實現(xiàn)詳解

    Spring?Data?JPA框架的Repository自定義實現(xiàn)詳解

    Spring?Data?JPA是Spring基于JPA規(guī)范的基礎上封裝的?套?JPA?應?框架,可使開發(fā)者?極簡的代碼即可實現(xiàn)對數(shù)據(jù)庫的訪問和操作,本篇我們來了解Spring?Data?JPA框架的Repository自定義實現(xiàn)
    2022-04-04
  • java自定義日期轉(zhuǎn)化類示例

    java自定義日期轉(zhuǎn)化類示例

    這篇文章主要介紹了java自定義日期轉(zhuǎn)化類示例,需要的朋友可以參考下
    2014-05-05
  • java線程的基礎實例解析

    java線程的基礎實例解析

    這篇文章主要介紹了java線程的基礎實例解析,具有一定借鑒價值,需要的朋友可以參考下
    2017-12-12
  • 關于Maven parent.relativePath說明

    關于Maven parent.relativePath說明

    Maven中的relativePath用于指定父項目pom.xml的相對路徑,默認值為../pom.xml,這個配置幫助Maven在構建時定位父模塊的位置,確保模塊間的依賴關系正確,relativePath可以指向本地或遠程倉庫中的父項目,如果不需要尋找父項目,可以將其設置為空
    2024-09-09
  • 使用Spring Security OAuth2實現(xiàn)單點登錄

    使用Spring Security OAuth2實現(xiàn)單點登錄

    在本教程中,我們將討論如何使用Spring Security OAuth和Spring Boot實現(xiàn)SSO - 單點登錄。感興趣的朋友跟隨小編一起看看吧
    2019-06-06
  • 關于Unsupported Media Type的解決方案

    關于Unsupported Media Type的解決方案

    在Web開發(fā)中,415錯誤表示服務器無法處理請求附帶的媒體格式,本文介紹了導致HTTP 415錯誤的原因以及解決該問題的兩種方法,首先,415錯誤通常是由于客戶端請求的內(nèi)容類型與服務器期望的不匹配引起的,例如,服務器可能期望JSON格式的數(shù)據(jù)
    2024-10-10
  • SpringSecurity認證流程詳解

    SpringSecurity認證流程詳解

    這篇文章主要介紹了SpringSecurity認證流程詳解,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-05-05
  • Java由淺入深學習數(shù)組的使用

    Java由淺入深學習數(shù)組的使用

    數(shù)組對于每一門編程語言來說都是重要的數(shù)據(jù)結(jié)構之一,當然不同語言對數(shù)組的實現(xiàn)及處理也不盡相同。Java?語言中提供的數(shù)組是用來存儲固定大小的同類型元素
    2022-05-05
  • Java?輸入輸出?IO?NIO?AIO三兄弟對比分析對比分析

    Java?輸入輸出?IO?NIO?AIO三兄弟對比分析對比分析

    這篇文章主要為大家介紹了Java?輸入輸出?IO?NIO?AIO三兄弟對比分析對比分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-04-04
  • IDEA+Maven搭建JavaWeb項目的方法步驟

    IDEA+Maven搭建JavaWeb項目的方法步驟

    本文主要介紹了IDEA+Maven搭建JavaWeb項目的方法步驟,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2021-11-11

最新評論