首页 > 其他分享> 文章详细

十一、原子更新器

2021-12-30 16:02:12 阅读：157 来源： 互联网

标签：十一 bankAccout 更新 public String myVar 原子 class BankAccout

使用目的：

以一种线程安全的方式操作非线程安全对象内的某些字段。

优点：

不用对对象加锁，只针对对象的某个属性进行原子类操作，提高并发性。

使用方式：

1、更新的对象属性必须使用public volatile修饰符。

2、因为对象的属性修改类型原子类都是抽象类，所以每次使用都必须使用静态方法newUpdater()创建一个更新器，并且需要设置想要更新的类和属性。

AtomicIntegerFieldUpdater：

public class AtomicIntegerFieldUpdaterDemo {

    public static void main(String[] args) throws InterruptedException {
        BankAccout bankAccout = new BankAccout();
        //  线程数量
        int count = 1000;
        //  CountDownLatch
        final CountDownLatch latch = new CountDownLatch(count);

        for (int i = 1; i <= count; i++) {
            new Thread(() -> {
                try {
                    bankAccout.transfer(bankAccout);
                } finally {
                    latch.countDown();
                }
            }, String.valueOf(i)).start();

        }
        latch.await();

        System.out.println(Thread.currentThread().getName() + "\t" + "------bankAccount:" + bankAccout.money);
    }
}

class BankAccout {
    String bankName = "ccb";

    public volatile int money = 0;

    AtomicIntegerFieldUpdater FieldUpdater = AtomicIntegerFieldUpdater.newUpdater(BankAccout.class, "money");

    public void transfer(BankAccout bankAccout) {
        FieldUpdater.incrementAndGet(bankAccout);
    }
}

AtomicReferenceFieldUpdater：

public class AtomicReferenceFieldUpdaterDemo {
    public static void main(String[] args) {
        MyVar myVar = new MyVar();

        for (int i = 1; i <= 5; i++) {
            new Thread(() -> {
                myVar.init(myVar);
            }, String.valueOf(i)).start();
        }
    }
}

class MyVar {
    public volatile Boolean isInit = Boolean.FALSE;
    AtomicReferenceFieldUpdater<MyVar, Boolean> FieldUpdater = AtomicReferenceFieldUpdater.newUpdater(MyVar.class, Boolean.class, "isInit");

    public void init(MyVar myVar) {
        if (FieldUpdater.compareAndSet(myVar, Boolean.FALSE, Boolean.TRUE)) {
            System.out.println(Thread.currentThread().getName() + "\t" + "---start init");
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "\t" + "---end init");
        } else {
            System.out.println(Thread.currentThread().getName() + "\t" + "---抢夺失败，已被其他线程占用");
        }
    }
}

标签：十一,bankAccout,更新,public,String,myVar,原子,class,BankAccout
来源： https://www.cnblogs.com/shiblog/p/15749229.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

十一、原子更新器