Java多线程中原子性操作类怎么用

• 攻略

技术Java多线程中原子性操作类怎么用小编给大家分享一下Java多线程中原子性操作类怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！前言：

边肖想和大家分享一下如何在Java多线程中使用原子操作类。相信大部分人还是不太了解。因此，我想分享这篇文章供你参考。希望你看完这篇文章后收获多多。让我们一起来看看。

前言：

在java5之后，我们接触到了线程的Atomic操作，也就是修改的时候只需要保证那一刻是安全的，对应打包之后就可以处理对象的并发修改。本文总结了原子系列类的用法，其中包含：.

Java多线程中原子性操作类怎么用

1. 基本类型的使用

publicclassAtomicTest{

/**

*常用方法列表。

*

* @ seeAtomicInteger # get()直接返回值。

* @ seeatomicintger # getandad(int)添加指定的数据并返回更改前的数据。

* @ seeatomicinteger # getanddecrement()减少1，返回减少前的数据。

* @ seeatomicintger # getandincrement()增加1，并返回增加前的数据。

* @ seeatomicintger # getandset(int)设置指定的数据，并在设置前返回数据。

* @ seeatomicintger # addandget(int)在添加指定数据后返回添加的数据。

* @ seeatomicinteger # decrementandget()减少1，并返回减少的值。

* @ seeatomicinteger # incrementandget()增加1并返回增加的值。

* @ seeatomicnteger # Lazyset(int)将仅在get时设置。

* @ seeatomicnteger # compareandset(int，int)尝试添加，然后比较，如果添加成功，则返回true，否则返回false。

**/

publicationstatinvitmain(String[]args){ 0

finaltatocticketticket=newatomiccket()；

for(inti=0；i3；I){ 0

new thread(NewRunnable(){ 0

@覆盖

          public void run() {
                    while (ticket.getCount() > 0) {
                        System.out.println(Thread.currentThread().getName() + " count: " + ticket.decrement());
                    }
                }
            }).start();
        }
    }
}
class AtomicTicket {
    public AtomicInteger count = new AtomicInteger(100);
    public int decrement() {
        return count.getAndDecrement();
    }
    public int getCount() {
        return count.get();
    }
}

Thread-0 count: 100
Thread-2 count: 98
Thread-1 count: 99
Thread-2 count: 96
Thread-0 count: 97
Thread-2 count: 94
Thread-2 count: 92
Thread-1 count: 95
中间省略...
Thread-1 count: 12
Thread-2 count: 7
Thread-0 count: 9
Thread-2 count: 5
Thread-1 count: 6
Thread-2 count: 3
Thread-0 count: 4
Thread-2 count: 1
Thread-1 count: 2

2. 数组类型的使用

public class AtomicIntegerArrayTest {
    /**
     * 常见的方法列表
     * @see AtomicIntegerArray#addAndGet(int, int) 执行加法，第一个参数为数组的下标，第二个参数为增加的数量，返回增加后的结果
     * @see AtomicIntegerArray#compareAndSet(int, int, int) 对比修改，参数1：数组下标，参数2：原始值，参数3，修改目标值，修改成功返回true否则false
     * @see AtomicIntegerArray#decrementAndGet(int) 参数为数组下标，将数组对应数字减少1，返回减少后的数据
     * @see AtomicIntegerArray#incrementAndGet(int) 参数为数组下标，将数组对应数字增加1，返回增加后的数据
     *
     * @see AtomicIntegerArray#getAndAdd(int, int) 和addAndGet类似，区别是返回值是变化前的数据
     * @see AtomicIntegerArray#getAndDecrement(int) 和decrementAndGet类似，区别是返回变化前的数据
     * @see AtomicIntegerArray#getAndIncrement(int) 和incrementAndGet类似，区别是返回变化前的数据
     * @see AtomicIntegerArray#getAndSet(int, int) 将对应下标的数字设置为指定值，第二个参数为设置的值，返回是变化前的数据
     */
    private final static AtomicIntegerArray ATOMIC_INTEGER_ARRAY = new AtomicIntegerArray(new int[]{1,2,3,4,5,6,7,8,9,10});
    public static void main(String []args) throws InterruptedException {
        Thread []threads = new Thread[10];
        for(int i = 0 ; i < 10 ; i++) {
            final int index = i;
            threads[i] = new Thread() {
                public void run() {
                    int original =  ATOMIC_INTEGER_ARRAY.get(index);
                    int result = ATOMIC_INTEGER_ARRAY.addAndGet(index, index + 1);
                    System.out.println("currentThread：" + Thread.currentThread().getName() + " , 原始值为：" + original + "，增加后的结果为：" + result);
                }
            };
            threads[i].start();
        }
        for(Thread thread : threads) {
            thread.join();
        }
        System.out.println("=========================>\n执行已经完成，结果列表：");
        for(int i = 0 ; i < ATOMIC_INTEGER_ARRAY.length() ; i++) {
            System.out.println(ATOMIC_INTEGER_ARRAY.get(i));
        }
    }
}

currentThread：Thread-0 , 原始值为：1，增加后的结果为：2
currentThread：Thread-3 , 原始值为：4，增加后的结果为：8
currentThread：Thread-2 , 原始值为：3，增加后的结果为：6
currentThread：Thread-1 , 原始值为：2，增加后的结果为：4
currentThread：Thread-5 , 原始值为：6，增加后的结果为：12
currentThread：Thread-4 , 原始值为：5，增加后的结果为：10
currentThread：Thread-6 , 原始值为：7，增加后的结果为：14
currentThread：Thread-7 , 原始值为：8，增加后的结果为：16
currentThread：Thread-8 , 原始值为：9，增加后的结果为：18
currentThread：Thread-9 , 原始值为：10，增加后的结果为：20
=========================>

执行已经完成，结果列表：
2
4
6
8
10
12
14
16
18
20

3. 引用类型的使用

public class AtomicReferenceTest {
    public static void main(String[] args) {
        People people1 =new People("Bom", 0);
        People people2 =new People("Tom",10);
        //先初始化一个值，如果不初始化则默认值为null
        AtomicReference<People> reference = new AtomicReference<>(people1);
        People people3 = reference.get();
        if (people3.equals(people1)) {
            System.out.println("people3:" + people3);
        } else {
            System.out.println("else:" + people3);
        }
        /**
         * 当前值：拿当前值和reference.get()获取到的值去比较，如果相等则true并更新值为期望值
         * 期望值：如果返回true则更新为期望值，如果返回false则不更新值
         */
        boolean b = reference.compareAndSet(null, people2);
        System.out.println("myClass.main-"+b+"--"+reference.get());
        boolean b1 = reference.compareAndSet(people1, people2);
        System.out.println("myClass.main-"+b1+"--"+reference.get());
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName());
                People people = reference.get();
                people.setName("Tom"+Thread.currentThread().getName());
                people.setAge(people.getAge()+1);
                reference.getAndSet(people);
                System.out.println(Thread.currentThread().getName()+reference.get().toString());
            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName());
                People people = reference.get();
                people.setName("Tom"+Thread.currentThread().getName());
                people.setAge(people.getAge()+4);
                reference.getAndSet(people);
                System.out.println(Thread.currentThread().getName()+reference.get().toString());
            }
        }).start();
    }
}
 class People {
    private String name;
    private int age;
    public People(String name, int age) {
        this.name = name;
        this.age = age;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    @Override
    public String toString() {
        return "People{" +
                "name='" + name + ''' +
                ", age=" + age +
                '}';
    }
}

4.字段类型的使用

public class AtomicIntegerFieldUpdaterTest {
    /**
     * 可以直接访问对应的变量，进行修改和处理
     * 条件：要在可访问的区域内，如果是private或挎包访问default类型以及非父亲类的protected均无法访问到
     * 其次访问对象不能是static类型的变量（因为在计算属性的偏移量的时候无法计算），也不能是final类型的变量（因为根本无法修改），必须是普通的成员变量
     * <p>
     * 方法（说明上和AtomicInteger几乎一致，唯一的区别是第一个参数需要传入对象的引用）
     *
     * @see AtomicIntegerFieldUpdater#addAndGet(Object, int)
     * @see AtomicIntegerFieldUpdater#compareAndSet(Object, int, int)
     * @see AtomicIntegerFieldUpdater#decrementAndGet(Object)
     * @see AtomicIntegerFieldUpdater#incrementAndGet(Object)
     * @see AtomicIntegerFieldUpdater#getAndAdd(Object, int)
     * @see AtomicIntegerFieldUpdater#getAndDecrement(Object)
     * @see AtomicIntegerFieldUpdater#getAndIncrement(Object)
     * @see AtomicIntegerFieldUpdater#getAndSet(Object, int)
     */
    public final static AtomicIntegerFieldUpdater<A> ATOMIC_INTEGER_UPDATER = AtomicIntegerFieldUpdater.newUpdater(A.class, "intValue");
    public static void main(String[] args) {
        final A a = new A();
        for (int i = 0; i < 10; i++) {
            new Thread() {
                public void run() {
                    System.out.println(
                            Thread.currentThread().getName() + " " + ATOMIC_INTEGER_UPDATER.get(a));
                    ATOMIC_INTEGER_UPDATER.addAndGet(a, 11);
                    System.out.println(
                            Thread.currentThread().getName() + " " + ATOMIC_INTEGER_UPDATER.get(a));
                    if (ATOMIC_INTEGER_UPDATER.compareAndSet(a, ATOMIC_INTEGER_UPDATER.get(a), 120)) {
                        System.out.println(Thread.currentThread().getName() + " 对应的值做了修改！");
                    }
                    System.out.println(
                            Thread.currentThread().getName() + " " + ATOMIC_INTEGER_UPDATER.get(a));
                }
            }.start();
        }
    }
    static class A {
        volatile int intValue = 100;
    }
}

Thread-0 100
Thread-2 100
Thread-1 100
Thread-2 122
Thread-3 111
Thread-5 120
Thread-0 111
Thread-5 142
Thread-3 131
Thread-2 对应的值做了修改！
Thread-2 120
Thread-8 120
Thread-4 133
Thread-1 133
Thread-9 142
Thread-4 142
Thread-4 对应的值做了修改！
Thread-8 131
Thread-3 对应的值做了修改！
Thread-3 120
Thread-7 120
Thread-7 131
Thread-5 对应的值做了修改！
Thread-5 120
Thread-6 120
Thread-0 对应的值做了修改！
Thread-6 131
Thread-7 对应的值做了修改！
Thread-8 对应的值做了修改！
Thread-4 120
Thread-9 131
Thread-1 对应的值做了修改！
Thread-9 对应的值做了修改！
Thread-8 120
Thread-7 120
Thread-6 对应的值做了修改！
Thread-0 131
Thread-6 120
Thread-9 120
Thread-1 120

以上是“Java多线程中原子性操作类怎么用”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注行业资讯频道！

内容来源网络，如有侵权，联系删除，本文地址：https://www.230890.com/zhan/60756.html

赞 (0)

相关推荐

  • html盒子模型由什么组成(html盒子模型具有哪些内容)

    技术html的盒子模型有哪些本篇内容主要讲解“html的盒子模型有哪些”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“html的盒子模型有哪些”吧!

    攻略 2021年12月23日

  • 怎么进行Nginx服务器的性能分析

    技术怎么进行Nginx服务器的性能分析今天就跟大家聊聊有关怎么进行Nginx服务器的性能分析，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。Nginx服务器一直在默

    攻略 2021年11月25日

  • 粉底液怎么用具体步骤,粉底液如何使用

    技术粉底液怎么用具体步骤,粉底液如何使用粉底液的使用可以用手也可以用粉扑粉底液怎么用具体步骤。 步骤一：先把粉底液涂抹在面部额头、下巴、面颊、鼻子五个点上，如果哪个部位毛孔较粗大，那么再取少量粉底液轻轻拍打，使粉底液融入

    生活 2021年10月22日

  • 市场前景好怎么形容,表示前景很好的四字成语

    技术市场前景好怎么形容,表示前景很好的四字成语1市场前景好怎么形容、前程似锦 2、鹏程万里 3、前途无量
    4、平步青云
    5、大展宏图1、 [拼音]：qián chéng sì jǐn[释义]：前程像锦绣那样。形容前途

    生活 2021年10月23日

  • 抖音刷双击秒刷,如何选择优质的刷赞平台

    技术抖音刷双击秒刷,如何选择优质的刷赞平台抖音的粉丝在哪儿买?怎样可以增加抖音的点赞和粉丝?现在很多人都喜欢抖音短视频,这段时间里,抖音很火,抖音挑战赛开始后,参与人数很多。每个人都在想如何才能拍出高质量的视频,观看量,

    测评 2021年10月21日
  • Eclipse如何汉化 攻略

    Eclipse如何汉化

    技术Eclipse如何汉化这篇文章给大家分享的是有关Eclipse如何汉化的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。1、安装好Eclipse2、下载专门负责 Eclipse 程序的多国语言

    2021年11月26日