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

王朝java/jsp·作者佚名  2006-01-09
窄屏简体版  字體: |||超大  

原子类

在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类的工作原理同理。

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航