Java AtomicInteger类的使用方法详解

不念不忘少年蓝@ 2022-04-22 04:22 192阅读 0赞

# Java AtomicInteger类的使用方法详解 #

更新时间：2017年10月10日 11:30:31   作者：叶长风   [![text-message.png][] 我要评论][text-message.png 1]

这篇文章主要介绍了Java AtomicInteger类的使用方法详解，文中有具体实例代码，具有一定参考价值，需要的朋友可以了解下。

[![phpcn.gif_1026][]][phpcn.gif_1026 1]

首先看两段代码，一段是Integer的，一段是AtomicInteger的，为以下：

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>public</code> <code>class</code> <code>Sample1 { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>Integer count = </code><code>0</code><code>;</code> <code>&nbsp;&nbsp;</code><code>synchronized</code> <code>public</code> <code>static</code> <code>void</code> <code>increment() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>count++;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

以下是AtomicInteger的：

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 </td> 
 <td> <code>public</code> <code>class</code> <code>Sample2 { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>AtomicInteger count = </code><code>new</code> <code>AtomicInteger(</code><code>0</code><code>);</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>static</code> <code>void</code> <code>increment() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>count.getAndIncrement();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

以上两段代码，在使用Integer的时候，必须加上synchronized保证不会出现并发线程同时访问的情况，而在AtomicInteger中却不用加上synchronized，在这里AtomicInteger是提供原子操作的，下面就对这进行相应的介绍。

**AtomicInteger介绍**

AtomicInteger是一个提供原子操作的Integer类，通过线程安全的方式操作加减。

**AtomicInteger使用场景**

AtomicInteger提供原子操作来进行Integer的使用，因此十分适合高并发情况下的使用。

**AtomicInteger源码部分讲解**

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>public</code> <code>class</code> <code>AtomicInteger </code><code>extends</code> <code>Number </code><code>implements</code> <code>java.io.Serializable { </code> <code>&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>final</code> <code>long</code> <code>serialVersionUID = 6214790243416807050L;</code> <code>&nbsp;&nbsp;</code><code>// setup to use Unsafe.compareAndSwapInt for updates</code> <code>&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>final</code> <code>Unsafe unsafe = Unsafe.getUnsafe();</code> <code>&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>final</code> <code>long</code> <code>valueOffset;</code> <code>&nbsp;&nbsp;</code><code>static</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>valueOffset = unsafe.objectFieldOffset</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>(AtomicInteger.</code><code>class</code><code>.getDeclaredField(</code><code>"value"</code><code>));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} </code><code>catch</code> <code>(Exception ex) { </code><code>throw</code> <code>new</code> <code>Error(ex); }</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>private</code> <code>volatile</code> <code>int</code> <code>value;</code> </td> 
 </tr> 
 </tbody> 
</table>

以上为AtomicInteger中的部分源码，在这里说下其中的value，这里value使用了volatile关键字，volatile在这里可以做到的作用是使得多个线程可以共享变量，但是问题在于使用volatile将使得VM优化失去作用，导致效率较低，所以要在必要的时候使用，因此AtomicInteger类不要随意使用，要在使用场景下使用。

**AtomicInteger实例使用**

以下就是在多线程情况下，使用AtomicInteger的一个实例，这段代码是借用IT宅中的一段代码。

[?][Link 1]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 </td> 
 <td> <code>public</code> <code>class</code> <code>AtomicTest { </code> <code>&nbsp;&nbsp;</code><code>static</code> <code>long</code> <code>randomTime() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>(</code><code>long</code><code>) (Math.random() * </code><code>1000</code><code>);</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>public</code> <code>static</code> <code>void</code> <code>main(String[] args) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 阻塞队列，能容纳100个文件</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>BlockingQueue&lt;File&gt; queue = </code><code>new</code> <code>LinkedBlockingQueue&lt;File&gt;(</code><code>100</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 线程池</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>ExecutorService exec = Executors.newFixedThreadPool(</code><code>5</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>File root = </code><code>new</code> <code>File(</code><code>"D:\\ISO"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 完成标志</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>File exitFile = </code><code>new</code> <code>File(</code><code>""</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 原子整型，读个数</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// AtomicInteger可以在并发情况下达到原子化更新，避免使用了synchronized，而且性能非常高。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>AtomicInteger rc = </code><code>new</code> <code>AtomicInteger();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 原子整型，写个数</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>AtomicInteger wc = </code><code>new</code> <code>AtomicInteger();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 读线程</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Runnable read = </code><code>new</code> <code>Runnable() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>run() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>scanFile(root);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>scanFile(exitFile);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>scanFile(File file) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>(file.isDirectory()) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>File[] files = file.listFiles(</code><code>new</code> <code>FileFilter() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>boolean</code> <code>accept(File pathname) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>pathname.isDirectory() || pathname.getPath().endsWith(</code><code>".iso"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code> <code>(File one : files)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>scanFile(one);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} </code><code>else</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 原子整型的incrementAndGet方法，以原子方式将当前值加 1，返回更新的值</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>int</code> <code>index = rc.incrementAndGet();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"Read0: "</code> <code>+ index + </code><code>" "</code> <code>+ file.getPath());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 添加到阻塞队列中</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>queue.put(file);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} </code><code>catch</code> <code>(InterruptedException e) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>};</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// submit方法提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exec.submit(read);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 四个写线程</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code> <code>(</code><code>int</code> <code>index = </code><code>0</code><code>; index &lt; </code><code>4</code><code>; index++) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// write thread</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>final</code> <code>int</code> <code>num = index;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Runnable write = </code><code>new</code> <code>Runnable() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>String threadName = </code><code>"Write"</code> <code>+ num;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>run() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>while</code> <code>(</code><code>true</code><code>) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Thread.sleep(randomTime());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 原子整型的incrementAndGet方法，以原子方式将当前值加 1，返回更新的值</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>int</code> <code>index = wc.incrementAndGet();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 获取并移除此队列的头部，在元素变得可用之前一直等待（如果有必要）。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>File file = queue.take();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 队列已经无对象</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>(file == exitFile) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 再次添加"标志"，以让其他线程正常退出</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>queue.put(exitFile);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>break</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(threadName + </code><code>": "</code> <code>+ index + </code><code>" "</code> <code>+ file.getPath());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} </code><code>catch</code> <code>(InterruptedException e) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>};</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exec.submit(write);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exec.shutdown();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**AtomicInteger使用总结**

AtomicInteger是在使用非阻塞算法实现并发控制，在一些高并发程序中非常适合，但并不能每一种场景都适合，不同场景要使用使用不同的数值类。

以上就是本文关于Java AtomicInteger类的使用方法详解的全部内容，希望对大家有所帮助。感兴趣的朋友可以参阅：[java原生序列化和Kryo序列化性能实例对比分析][java_Kryo] 、[关于Java企业级项目开发思想][Java] 、[Java map存放数组并取出值代码详解][Java map] 等，有什么问题可以随时留言，小编会及时回复大家。

[text-message.png]: https://www.jb51.net/skin/2018/images/text-message.png
[text-message.png 1]: https://www.jb51.net/article/125391.htm#comments
[phpcn.gif_1026]: https://files.jb51.net/image/phpcn.gif?1026
[phpcn.gif_1026 1]: http://www.php.cn/course.html?ad51
[Link 1]: https://www.jb51.net/article/125391.htm#
[java_Kryo]: https://www.jb51.net/article/125245.htm
[Java]: https://www.jb51.net/article/124938.htm
[Java map]: https://www.jb51.net/article/125097.htm