- Java并发教程
- 并发 - 主页
- 并发 - 概述
- 并发 - 环境设置
- 并发-主要操作
- 线程间通信
- 并发-同步
- 并发-死锁
- 实用程序类示例
- 并发-ThreadLocal
- 并发 - ThreadLocalRandom
- 锁示例
- 并发-锁
- 并发-ReadWriteLock
- 并发-条件
- 原子变量示例
- 并发-AtomicInteger
- 并发-AtomicLong
- 并发 - AtomicBoolean
- 并发 - AtomicReference
- 并发 - AtomicIntegerArray
- 并发-AtomicLongArray
- 并发 - AtomicReferenceArray
- 执行器示例
- 并发-执行器
- 并发-ExecutorService
- 预定执行服务
- 线程池示例
- 并发-newFixedThreadPool
- 并发-newCachedThreadPool
- 新的调度线程池
- 新的单线程执行器
- 并发-ThreadPoolExecutor
- 调度线程池执行器
- 高级示例
- 并发 - Futures 和 Callables
- 并发 - Fork-Join 框架
- 并发集合
- 并发-BlockingQueue
- 并发 - ConcurrentMap
- 并发导航地图
- 并发有用的资源
- 并发 - 快速指南
- 并发 - 有用的资源
- 并发 - 讨论
Java 并发 - AtomicLong 类
java.util.concurrent.atomic.AtomicLong 类提供对基础 long 值的操作,这些操作可以Atomics方式读取和写入,并且还包含高级Atomics操作。AtomicLong 支持对底层 long 变量进行Atomics操作。它具有 get 和 set 方法,其工作方式类似于对易失性变量进行读取和写入。也就是说,集合与同一变量上的任何后续获取具有先发生关系。AtomicscompareAndSet方法也具有这些内存一致性特征。
Atomics长方法
以下是 AtomicLong 类中可用的重要方法的列表。
| 先生。 | 方法及说明 |
|---|---|
| 1 | 公共长addAndGet(长增量) 以Atomics方式将给定值添加到当前值。 |
| 2 | public boolean CompareAndSet(长期期待,长期更新) 如果当前值与预期值相同,则自动将该值设置为给定的更新值。 |
| 3 | 公共长减量AndGet() 以Atomics方式将当前值减一。 |
| 4 | 公共双倍双值() 以双精度形式返回指定数字的值。 |
| 5 | 公共浮点数 floatValue() 以浮点数形式返回指定数字的值。 |
| 6 | 公共长get() 获取当前值。 |
| 7 | 公共长 getAndAdd(长增量) 以Atomics方式将给定值添加到当前值。 |
| 8 | 公共长 getAndDecrement() 以Atomics方式将当前值减一。 |
| 9 | 公共长 getAndIncrement() 以Atomics方式将当前值加一。 |
| 10 | 公共长 getAndSet(长 newValue) Atomics地设置为给定值并返回旧值。 |
| 11 | 公共长增量AndGet() 以Atomics方式将当前值加一。 |
| 12 | 公共 int intValue() 以 int 形式返回指定数字的值。 |
| 13 | 公共无效lazySet(长newValue) 最终设置为给定值。 |
| 14 | 公共长长值() 以 long 形式返回指定数字的值。 |
| 15 | 公共无效集(长新值) 设置为给定值。 |
| 16 | 公共字符串 toString() 返回当前值的字符串表示形式。 |
| 17 号 | 公共布尔weakCompareAndSet(长期期望,长期更新) 如果当前值与预期值相同,则自动将该值设置为给定的更新值。 |
例子
以下 TestThread 程序显示了在基于线程的环境中使用 AtomicLong 的计数器的安全实现。
import java.util.concurrent.atomic.AtomicLong;
public class TestThread {
static class Counter {
private AtomicLong c = new AtomicLong(0);
public void increment() {
c.getAndIncrement();
}
public long value() {
return c.get();
}
}
public static void main(final String[] arguments) throws InterruptedException {
final Counter counter = new Counter();
//1000 threads
for(int i = 0; i < 1000 ; i++) {
new Thread(new Runnable() {
public void run() {
counter.increment();
}
}).start();
}
Thread.sleep(6000);
System.out.println("Final number (should be 1000): " + counter.value());
}
}
这将产生以下结果。
输出
Final number (should be 1000): 1000