快捷導(dǎo)航

Java原子類中的AtomicInteger類詳解

更新時(shí)間：2023年10月24日 09:34:08 作者：liyong0829

這篇文章主要介紹了Java原子類中的AtomicInteger類詳解,原子類可以保證對(duì)"變量"操作的,原子性、有序性、可見(jiàn)性,我們可以通過(guò)AtomicInteger類,來(lái)看看它們是怎樣工作的,需要的朋友可以參考下

原子類

在java.util.concurrent.atomic包下定義了一些對(duì)“變量”操作的“原子類”:

java.util.concurrent.atomic.AtomicInteger：對(duì)int變量操作的“原子類”;
java.util.concurrent.atomic.AtomicLong：對(duì)long變量操作的“原子類”;
java.util.concurrent.atomic.AtomicBoolean：對(duì)boolean變量操作的“原子類”;

它們可以保證對(duì)“變量”操作的：原子性、有序性、可見(jiàn)性。

AtomicInteger類示例

我們可以通過(guò)AtomicInteger類，來(lái)看看它們是怎樣工作的

//線程類：

public class MyThread extends Thread {
     //static int a = 0;
    static AtomicInteger a = new AtomicInteger();// 表示整數(shù)0

    @Override
    public void run() {
        for (int i = 0; i < 200000; i++) {
            // a++;
            a.getAndIncrement();
        }
        System.out.println("子線程執(zhí)行完畢");
    }
}

//測(cè)試類：

public class Test {
    public static void main(String[] args) throws InterruptedException {

        // 案例:一條子線程和一條主線程都對(duì)共享變量a進(jìn)行++操作,每條線程對(duì)a++操作400000次
        new MyThread().start();

        for (int i = 0; i < 200000; i++) {
            //MyThread.a++;
            MyThread.a.getAndIncrement();
        }

        // 為了保證子線程和主線程都執(zhí)行完畢
        Thread.sleep(3000);

        // 打印最終共享變量a的值(子線程,主線程對(duì)a的操作都執(zhí)行完畢了)
        System.out.println("最終:"+ MyThread.a.get());

  }
}

我們能看到，無(wú)論程序運(yùn)行多少次，其結(jié)果總是正確的！

AtomicInteger類的工作原理-CAS機(jī)制

在這里插入圖片描述

AtomicIntegerArray類示例

常用的數(shù)組操作的原子類：

1).java.util.concurrent.atomic.AtomicIntegerArray:對(duì)int數(shù)組操作的原子類。 int[]

2).java.util.concurrent.atomic.AtomicLongArray：對(duì)long數(shù)組操作的原子類。long[]

3).java.util.concurrent.atomic.AtomicReferenceArray：對(duì)引用類型數(shù)組操作的原子類。Object[]

數(shù)組的多線程并發(fā)訪問(wèn)的安全性問(wèn)題：

//線程類：

public class MyThread extends Thread {
    public static int[] arr = new int[1000];

    @Override
    public void run() {
        for (int i = 0; i < arr.length(); i++) {
            arr[i]++;
        }
        System.out.println("結(jié)束");
    }
}

//測(cè)試類：

public class Demo {
    public static void main(String[] args) throws InterruptedException {
        for (int i = 0; i < 1000; i++) {
            new MyThread().start();//創(chuàng)建1000個(gè)線程，每個(gè)線程為數(shù)組的每個(gè)元素+1
        }

        Thread.sleep(1000 * 5);//讓所有線程執(zhí)行完畢

        System.out.println("主線程休息5秒醒來(lái)");
        for (int i = 0; i < MyThread.arr.length; i++) {
            System.out.println(MyThread.arr[i]);
        }
    }
}

//正常情況，數(shù)組的每個(gè)元素最終結(jié)果應(yīng)為：1000，而實(shí)際打?。?/p>

1000
1000
1000
1000
999
999
999
999
999
999
999
999
1000
1000
1000
1000

可以發(fā)現(xiàn)，有些元素并不是1000.

//為保證數(shù)組的多線程安全，改用AtomicIntegerArray類，演示：

//線程類：

public class MyThread extends Thread {
 
    //改用原子類，使用數(shù)組構(gòu)造
    public static AtomicIntegerArray arr = new AtomicIntegerArray(1000);
    @Override
    public void run() {
        for (int i = 0; i < arr.length(); i++) {
            arr.addAndGet(i, 1);//將i位置上的元素 + 1
        }
        System.out.println("結(jié)束");
    }
}

測(cè)試類

  public class Demo {
      public static void main(String[] args) throws InterruptedException {
          for (int i = 0; i < 1000; i++) {
              new MyThread().start();
          }
          Thread.sleep(1000 * 5);//讓所有線程執(zhí)行完畢
  
          System.out.println("主線程休息5秒醒來(lái)");
          for (int i = 0; i < MyThread.arr.length(); i++) {
              System.out.println(MyThread.arr.get(i));
          }
      }
  }

先在能看到，每次運(yùn)行的結(jié)果都是正確的。

到此這篇關(guān)于Java原子類中的AtomicInteger類詳解的文章就介紹到這了,更多相關(guān)Java的AtomicInteger類內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: