java线程并发包util.concurrent的研究(三)

类别:Java 点击:0 评论:0 推荐:
原子类
在Dawid Kurzyniec先生的util.concurrent包中最基本的类就是在edu.mory.mathcs.backport.java.util.concurrent.atomic中的原子类了。
下面本人先从AtomicInteger类look。。

AtomicInteger类说明:

一个整数值可以被原子地更新。一个AtomicInteger作为原子增长计数器被用在应用程序中,不能够替换java.lang.Integer使用。但是这个类是Number抽象类的扩展,可以被处理基于number类的工具访问。

以下便是AtomicInteger的源代码:

//AtomicInteger类扩展了Number类,并且可序列化

public class AtomicInteger extends Number implements java.io.Serializable {

private static final long serialVersionUID = 6214790243416807050L;

//整数值

private int value;

 

/**

* 使用初始化值构造一个AtomicInteger.

*

* @param 初始化值

*/

public AtomicInteger(int initialValue) {

value = initialValue;

}

 

/**

* 使用0构造一个AtomicInteger..

*/

public AtomicInteger() {

}

 

/**

* 获取AtomicInteger的值.

*

* @return 返回AtomicInteger的当前值

*/

public final synchronized int get() {

return value;

}

 

/**

* 给AtomicInteger赋新值

*

* @param 传入的新值

*/

public final synchronized void set(int newValue) {

value = newValue;

}

 

    /**

     * 设置新值,返回旧值.

     *

     * @param 传入的新值

     * @return 返回旧值

     */

    public final synchronized int getAndSet(int newValue) {

        int old = value;

        value = newValue;

        return old;

}

 

    /**

     * 原子地更新指定值为新值

     * 如果当前值等于期待的值(expect)

     * @param 期待的值

     * @param 传入的新值

     * @return 如果更新成功,返回true。否则返回False

     */

    public final synchronized boolean compareAndSet(int expect, int update) {

        boolean success = (expect == value);

        if (success)

            value = update;

        return success;

}

      

/**

     * 原子地更新指定值为新值

     * 如果当前值等于期待值(expect).

     * 可能会不真实的失败.

     * @param 期待值

     * @param 传入的新值

     * @return如果更新成功,返回true。

     */

    public final synchronized boolean weakCompareAndSet(int expect, int update) {

        boolean success = (expect == value);

        if (success)

            value = update;

        return success;

}

 

/**

     * 原子地递增1

     * @return 返回增加前的旧值

     */

    public final synchronized int getAndIncrement() {

        return value++;

}

      

       /**

     * 原子地递增1

     * @return 返回增加后的新值

     */

    public final synchronized int incrementAndGet() {

        return ++value;

}

 

/**

     * 原子地递减1

     * @return 返回递减前的旧值

     */

    public final synchronized int getAndDecrement() {

        return value--;

}

      

       /**

     * 原子地递减1

     * @return 返回递减后的新值

     */

    public final synchronized int decrementAndGet() {

        return --value;

}

      

/**

     * 原子地增加某个增量(delta)

     * @param 增量delta

     * @return 返回增加前的旧值

     */

    public final synchronized int getAndAdd(int delta) {

        int old = value;

        value += delta;

        return old;

}

      

/**

     * 原子地增加某个增量(delta)

     * @param增量delta

     * @return返回增加后的新值

     */

    public final synchronized int addAndGet(int delta) {

        return value += delta;

    }

      

       /**

     * 原子地更新旧值为新值

     *

     * @param 传入的新值

     * @return 返回旧值

     */

    public final synchronized int getAndSet(int newValue) {

        int old = value;

        value = newValue;

        return old;

}

      

/**

     * 返回当前值的字符串表达式.

     * @return返回当前值的字符串表达式.

     */

    public String toString() {

        return Integer.toString(get());

    }

 

 

    public int intValue() {

        return get();

    }

 

    public long longValue() {

        return (long)get();

    }

 

    public float floatValue() {

        return (float)get();

    }

 

    public double doubleValue() {

        return (double)get();

}

}

总得来说,基本工作原理是使用了同步synchronized的方法实现了对一个整型数值的增、减、赋值(更新)。使对AtomicInteger的值操作成为原子操作。

另外的AtomicLong、AtomicLongArray、AtomicIntegerArray、AtomicBoolean、AtomicReference、AtomicMarkableReference、AtomicReferenceArray、AtomicStampedReference类的工作原理同理。

本文地址:http://com.8s8s.com/it/it11878.htm