這篇文章給大家介紹AtomicInteger類如何在Java項(xiàng)目中使用，內(nèi)容非常詳細(xì)，感興趣的小伙伴們可以參考借鑒，希望對(duì)大家能有所幫助。
成都創(chuàng)新互聯(lián)專業(yè)為企業(yè)提供新洲網(wǎng)站建設(shè)、新洲做網(wǎng)站、新洲網(wǎng)站設(shè)計(jì)、新洲網(wǎng)站制作等企業(yè)網(wǎng)站建設(shè)、網(wǎng)頁設(shè)計(jì)與制作、新洲企業(yè)網(wǎng)站模板建站服務(wù)，10余年新洲做網(wǎng)站經(jīng)驗(yàn)，不只是建網(wǎng)站，更提供有價(jià)值的思路和整體網(wǎng)絡(luò)服務(wù)。
首先看兩段代碼，一段是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是提供原子操作的，下面就對(duì)這進(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 queue = new LinkedBlockingQueue(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)無對(duì)象
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)于AtomicInteger類如何在Java項(xiàng)目中使用就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。
