java.util.concurrent.atomic包 :原子类的小工具包,支持在单个变量上解除锁的线程安全编程。
原子变量类相当于一种泛化的 volatile 变量,能够支持原子的和有条件的读-改-写操作。
AtomicInteger 表示一个int类型的值,并提供了 get 和 set 方法,这些 Volatile 类型的int变量在读取和写入上有着相同的内存语义。它还提供了一个原子的 compareAndSet 方法(如果该方法成功执行,那么将实现与读取/写入一个 volatile 变量相同的内存效果),以及原子的添加、递增和递减等方法。AtomicInteger 表面上非常像一个扩展的 Counter 类,但在发生竞争的情况下能提供更高的可伸缩性,因为它直接利用了硬件对并发的支持。
如果同一个变量要被多个线程访问,则可以使用该包中的类:
- AtomicBoolean
- AtomicInteger
- AtomicLong
- AtomicReference
常用原子类:
Java中的原子操作类大致可以分为4类:原子更新基本类型、原子更新数组类型、原子更新引用类型、原子更新属性类型。这些原子类中都是用了无锁的概念,有的地方直接使用CAS操作的线程安全的类型。
- AtomicBoolean
- AtomicInteger
- AtomicLong
- AtomicReference
package com.ylw.thread; import java.util.concurrent.atomic.AtomicInteger; public class AutomaticDemo implements Runnable { private static Integer count = 1; private static AtomicInteger atomic = new AtomicInteger(); @Override public void run() { while (true) { int count = getCountAtomic();//使用AtomicInteger //int count = AutomaticDemo.count;//不使用AtomicInteger System.out.println(count); if (count >= 150) { break; } } } public synchronized Integer getCount() { try { Thread.sleep(50); } catch (Exception e) { // TODO: handle exception } return count++; } public Integer getCountAtomic() { try { Thread.sleep(50); } catch (Exception e) { // TODO: handle exception } return atomic.incrementAndGet(); } public static void main(String[] args) { AutomaticDemo runnable = new AutomaticDemo(); Thread t1 = new Thread(runnable); Thread t2 = new Thread(runnable); t1.start(); t2.start(); } }