快捷導(dǎo)航

Java AtomicInteger類的使用方法詳解

更新時(shí)間：2017年10月10日 11:30:31 作者：葉長風(fēng)

這篇文章主要介紹了Java AtomicInteger類的使用方法詳解，文中有具體實(shí)例代碼，具有一定參考價(jià)值，需要的朋友可以了解下。

首先看兩段代碼，一段是Integer的，一段是AtomicInteger的，為以下：

public class Sample1 {
  private static Integer count = 0;
  synchronized public static void increment() {
    count++;
  }
}

以下是AtomicInteger的：

public class Sample2 {
  private static AtomicInteger count = new AtomicInteger(0);
  public static void increment() {
    count.getAndIncrement();
  }
}

以上兩段代碼，在使用Integer的時(shí)候，必須加上synchronized保證不會(huì)出現(xiàn)并發(fā)線程同時(shí)訪問的情況，而在AtomicInteger中卻不用加上synchronized，在這里AtomicInteger是提供原子操作的，下面就對這進(jìn)行相應(yīng)的介紹。

AtomicInteger介紹

AtomicInteger是一個(gè)提供原子操作的Integer類，通過線程安全的方式操作加減。

AtomicInteger使用場景

AtomicInteger提供原子操作來進(jìn)行Integer的使用，因此十分適合高并發(fā)情況下的使用。

AtomicInteger源碼部分講解

public class AtomicInteger extends Number implements java.io.Serializable {
  private static final long serialVersionUID = 6214790243416807050L;
  // setup to use Unsafe.compareAndSwapInt for updates
  private static final Unsafe unsafe = Unsafe.getUnsafe();
  private static final long valueOffset;
  static {
    try {
      valueOffset = unsafe.objectFieldOffset
        (AtomicInteger.class.getDeclaredField("value"));
    } catch (Exception ex) { throw new Error(ex); }
  }
  private volatile int value;

以上為AtomicInteger中的部分源碼，在這里說下其中的value，這里value使用了volatile關(guān)鍵字，volatile在這里可以做到的作用是使得多個(gè)線程可以共享變量，但是問題在于使用volatile將使得VM優(yōu)化失去作用，導(dǎo)致效率較低，所以要在必要的時(shí)候使用，因此AtomicInteger類不要隨意使用，要在使用場景下使用。

AtomicInteger實(shí)例使用

以下就是在多線程情況下，使用AtomicInteger的一個(gè)實(shí)例，這段代碼是借用IT宅中的一段代碼。

 public class AtomicTest {
  static long randomTime() {
    return (long) (Math.random() * 1000);
  }
  public static void main(String[] args) {
    // 阻塞隊(duì)列，能容納100個(gè)文件
    final BlockingQueue<File> queue = new LinkedBlockingQueue<File>(100);
    // 線程池
    final ExecutorService exec = Executors.newFixedThreadPool(5);
    final File root = new File("D:\\ISO");
    // 完成標(biāo)志
    final File exitFile = new File("");
    // 原子整型，讀個(gè)數(shù)
    // AtomicInteger可以在并發(fā)情況下達(dá)到原子化更新，避免使用了synchronized，而且性能非常高。
    final AtomicInteger rc = new AtomicInteger();
    // 原子整型，寫個(gè)數(shù)
    final AtomicInteger wc = new AtomicInteger();
    // 讀線程
    Runnable read = new Runnable() {
      public void run() {
        scanFile(root);
        scanFile(exitFile);
      }
      public void scanFile(File file) {
        if (file.isDirectory()) {
          File[] files = file.listFiles(new FileFilter() {
            public boolean accept(File pathname) {
              return pathname.isDirectory() || pathname.getPath().endsWith(".iso");
            }
          });
          for (File one : files)
            scanFile(one);
        } else {
          try {
            // 原子整型的incrementAndGet方法，以原子方式將當(dāng)前值加 1，返回更新的值
            int index = rc.incrementAndGet();
            System.out.println("Read0: " + index + " " + file.getPath());
            // 添加到阻塞隊(duì)列中
            queue.put(file);
          } catch (InterruptedException e) {
          }
        }
      }
    };
    // submit方法提交一個(gè) Runnable 任務(wù)用于執(zhí)行，并返回一個(gè)表示該任務(wù)的 Future。
    exec.submit(read);
    // 四個(gè)寫線程
    for (int index = 0; index < 4; index++) {
      // write thread
      final int num = index;
      Runnable write = new Runnable() {
        String threadName = "Write" + num;
        public void run() {
          while (true) {
            try {
              Thread.sleep(randomTime());
              // 原子整型的incrementAndGet方法，以原子方式將當(dāng)前值加 1，返回更新的值
              int index = wc.incrementAndGet();
              // 獲取并移除此隊(duì)列的頭部，在元素變得可用之前一直等待（如果有必要）。
              File file = queue.take();
              // 隊(duì)列已經(jīng)無對象
              if (file == exitFile) {
                // 再次添加"標(biāo)志"，以讓其他線程正常退出
                queue.put(exitFile);
                break;
              }
              System.out.println(threadName + ": " + index + " " + file.getPath());
            } catch (InterruptedException e) {
            }
          }
        }
      };
      exec.submit(write);
    }
    exec.shutdown();
  }
}

AtomicInteger使用總結(jié)

AtomicInteger是在使用非阻塞算法實(shí)現(xiàn)并發(fā)控制，在一些高并發(fā)程序中非常適合，但并不能每一種場景都適合，不同場景要使用使用不同的數(shù)值類。

以上就是本文關(guān)于Java AtomicInteger類的使用方法詳解的全部內(nèi)容，希望對大家有所幫助。感興趣的朋友可以參閱：java原生序列化和Kryo序列化性能實(shí)例對比分析、關(guān)于Java企業(yè)級項(xiàng)目開發(fā)思想、Java map存放數(shù)組并取出值代碼詳解等，有什么問題可以隨時(shí)留言，小編會(huì)及時(shí)回復(fù)大家。

您可能感興趣的文章: