您当前的位置: 首页 > 

并发编程系列教程(11) - 原子类

杨林伟 发布时间:2019-10-25 17:10:24 ,浏览量:5

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();
    }
}

关注
打赏
1688896170
查看更多评论

杨林伟

暂无认证

  • 5浏览

    0关注

    3183博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文
立即登录/注册

微信扫码登录

0.2122s