- 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