詳細(xì)總結(jié)Java中常用的原子類
一、什么是原子類
Java中提供了一些原子類，原子類包裝了一個(gè)變量，并且提供了一系列對(duì)變量進(jìn)行原子性操作的方法。我們?cè)诙嗑€程環(huán)境下對(duì)這些原子類進(jìn)行操作時(shí)，不需要加鎖，大大簡化了并發(fā)編程的開發(fā)。
二、原子類的底層實(shí)現(xiàn)
目前Java中提供的原子類大部分底層使用了CAS鎖（CompareAndSet自旋鎖），如AtomicInteger、AtomicLong等；也有使用了分段鎖+CAS鎖的原子類，如LongAdder等。
三、常用的原子類
3.1 AtomicInteger與AtomicLong
AtomicInteger與AtomicLong的底層實(shí)現(xiàn)與用法基本相同，不同點(diǎn)在于AtomicInteger包裝了一個(gè)Integer型變量，而AtomicLong包裝了一個(gè)Long型變量。
AtomicInteger與AtomicLong的底層實(shí)現(xiàn)都使用了CAS鎖。
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
/**
* @author IT00ZYQ
* @date 2021/5/24 15:33
**/
public class T13_AtomicInteger {
private static AtomicInteger atomicInteger = new AtomicInteger();
private static AtomicLong atomicLong = new AtomicLong();
private static Integer integer = 0;
private static Long lon = 0L;
public static void main(String[] args) {
// 創(chuàng)建10個(gè)線程，分別對(duì)atomicInteger、atomicLong、integer、lon進(jìn)行1000次增加1的操作
// 如果操作是原子性的，那么正確結(jié)果 = 10 * 1000 = 10000
Thread[] threads = new Thread[10];
for (int i = 0; i < 10; i++) {
threads[i] = new Thread(() -> {
for (int j = 1; j <= 1000; j++) {
atomicInteger.incrementAndGet();
atomicLong.incrementAndGet();
integer ++;
lon ++;
}
});
}
// 啟動(dòng)線程
for (Thread thread : threads) {
thread.start();
}
// 保證10個(gè)線程運(yùn)行完成
try {
for (Thread thread : threads) {
thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("AtomicInteger的結(jié)果：" + atomicInteger);
System.out.println("AtomicLong的結(jié)果：" + atomicLong);
System.out.println("Integer的結(jié)果：" + integer);
System.out.println("Long的結(jié)果：" + lon);
}
}
運(yùn)行結(jié)果：
AtomicInteger的結(jié)果：10000
AtomicLong的結(jié)果：10000
Integer的結(jié)果：4880
Long的結(jié)果：4350
Process finished with exit code 0
多次運(yùn)行發(fā)現(xiàn)原子類AtomicInteger與AtomicLong每次都能得到正確的結(jié)果10000，但是非原子類Integer與Long一般情況下都達(dá)不到10000，每次的結(jié)果也可能不一樣。
3.2 LongAdder
LongAdder的底層實(shí)現(xiàn)使用了分段鎖，每個(gè)段使用的鎖是CAS鎖，所以LongAdder的底層實(shí)現(xiàn)是分段鎖+CAS鎖。
在上面的程序添加了一個(gè)LongAdder變量進(jìn)行測(cè)試
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.LongAdder;
/**
* @author IT00ZYQ
* @date 2021/5/24 15:33
**/
public class T13_AtomicInteger {
private static AtomicInteger atomicInteger = new AtomicInteger();
private static AtomicLong atomicLong = new AtomicLong();
private static LongAdder longAdder = new LongAdder();
private static Integer integer = 0;
private static Long lon = 0L;
public static void main(String[] args) {
// 創(chuàng)建10個(gè)線程，分別對(duì)atomicInteger、atomicLong、integer、lon進(jìn)行1000次增加1的操作
// 如果操作是原子性的，那么正確結(jié)果 = 10 * 1000 = 10000
Thread[] threads = new Thread[10];
for (int i = 0; i < 10; i++) {
threads[i] = new Thread(() -> {
for (int j = 1; j <= 1000; j++) {
atomicInteger.incrementAndGet();
atomicLong.incrementAndGet();
integer ++;
lon ++;
longAdder.increment();
}
});
}
// 啟動(dòng)線程
for (Thread thread : threads) {
thread.start();
}
// 保證10個(gè)線程運(yùn)行完成
try {
for (Thread thread : threads) {
thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("AtomicInteger的結(jié)果：" + atomicInteger);
System.out.println("AtomicLong的結(jié)果：" + atomicLong);
System.out.println("Integer的結(jié)果：" + integer);
System.out.println("Long的結(jié)果：" + lon);
System.out.println("LongAdder的結(jié)果：" + longAdder);
}
}
運(yùn)行結(jié)果：
AtomicInteger的結(jié)果：10000
AtomicLong的結(jié)果：10000
Integer的結(jié)果：6871
Long的結(jié)果：6518
LongAdder的結(jié)果：10000
Process finished with exit code 0
LongAdder類也是能夠正確輸出結(jié)果的。
四、原子類的性能測(cè)試
4.1 測(cè)試程序
package juc;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.LongAdder;
/**
* @author IT00ZYQ
* @date 2021/5/24 15:51
**/
public class T14_AtomicClassPerformance {
private static AtomicLong atomicLong = new AtomicLong();
private static LongAdder longAdder = new LongAdder();
/**
* 線程數(shù)
*/
private static final int THREAD_COUNT = 100;
/**
* 每次線程循環(huán)操作次數(shù)
*/
private static final int OPERATION_COUNT = 10000;
public static void main(String[] args) {
Thread[] threads = new Thread[THREAD_COUNT];
// 創(chuàng)建對(duì)AtomicLong進(jìn)行操作的線程
for (int i = 0; i < THREAD_COUNT; i++) {
threads[i] = new Thread(() -> {
for (int j = 0; j < OPERATION_COUNT; j++) {
atomicLong.incrementAndGet();
}
});
}
long start1 = System.currentTimeMillis();
// 啟動(dòng)線程
for (Thread thread : threads) {
thread.start();
}
// 保證線程運(yùn)行完成
try {
for (Thread thread : threads) {
thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
long end1 = System.currentTimeMillis();
// 創(chuàng)建對(duì)LongAdder進(jìn)行操作的線程
for (int i = 0; i < THREAD_COUNT; i++) {
threads[i] = new Thread(() -> {
for (int j = 0; j < OPERATION_COUNT; j++) {
longAdder.increment();
}
});
}
long start2 = System.currentTimeMillis();
// 啟動(dòng)線程
for (Thread thread : threads) {
thread.start();
}
// 保證線程運(yùn)行完成
try {
for (Thread thread : threads) {
thread.join();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
long end2 = System.currentTimeMillis();
System.out.println("AtomicLong運(yùn)行時(shí)間: " + (end1 - start1) + "ms, 運(yùn)行結(jié)果：" + atomicLong);
System.out.println("LongAdder運(yùn)行時(shí)間: " + (end2 - start2) + "ms, 運(yùn)行結(jié)果：" + longAdder);
}
}
4.2 測(cè)試結(jié)果
THREAD_COUNT = 100, OPERATION_COUNT = 1000時(shí)的運(yùn)行結(jié)果
AtomicLong運(yùn)行時(shí)間: 40ms, 運(yùn)行結(jié)果：100000
LongAdder運(yùn)行時(shí)間: 57ms, 運(yùn)行結(jié)果：100000
Process finished with exit code 0
THREAD_COUNT = 100, OPERATION_COUNT = 10000時(shí)的運(yùn)行結(jié)果
AtomicLong運(yùn)行時(shí)間: 108ms, 運(yùn)行結(jié)果：1000000
LongAdder運(yùn)行時(shí)間: 85ms, 運(yùn)行結(jié)果：1000000
Process finished with exit code 0
THREAD_COUNT = 100, OPERATION_COUNT = 1000000時(shí)的運(yùn)行結(jié)果
AtomicLong運(yùn)行時(shí)間: 6909ms, 運(yùn)行結(jié)果：100000000
LongAdder運(yùn)行時(shí)間: 468ms, 運(yùn)行結(jié)果：100000000
Process finished with exit code 0
THREAD_COUNT = 10, OPERATION_COUNT = 1000000時(shí)的運(yùn)行結(jié)果
AtomicLong運(yùn)行時(shí)間: 788ms, 運(yùn)行結(jié)果：10000000
LongAdder運(yùn)行時(shí)間: 162ms, 運(yùn)行結(jié)果10000000
Process finished with exit code 0
4.3 結(jié)果分析
當(dāng)THREAD_COUNT * OPERATION_COUN足夠小時(shí)，AtomicInteger的性能會(huì)略高于LongAdder，而隨著THREAD_COUNT * OPERATION_COUN的增加，LongAdder的性能更高，THREAD_COUNT * OPERATION_COUN足夠大時(shí)，LongAdder的性能遠(yuǎn)高于AtomicInteger。
4.4 底層實(shí)現(xiàn)分析
- AtomicLong的原子性自增操作，是通過CAS實(shí)現(xiàn)的。在競(jìng)爭(zhēng)線程數(shù)較少且每個(gè)線程的運(yùn)行所需時(shí)間較短的情況下，這樣做是合適的。但是如果線程競(jìng)爭(zhēng)激烈，會(huì)造成大量線程在原地打轉(zhuǎn)、不停嘗試去修改值，但是老是發(fā)現(xiàn)值被修改了，于是繼續(xù)自旋。 這樣浪費(fèi)了大量的CPU資源。
- LongAdder在競(jìng)爭(zhēng)激烈時(shí)，多個(gè)線程并不會(huì)一直自旋來修改值，而是采用了分段的思想，各個(gè)線程會(huì)分散累加到自己所對(duì)應(yīng)的Cell[]數(shù)組的某一個(gè)數(shù)組對(duì)象元素中，而不會(huì)大家共用一個(gè)，把不同線程對(duì)應(yīng)到不同的Cell中進(jìn)行修改，降低了對(duì)臨界資源的競(jìng)爭(zhēng)。本質(zhì)上，是用空間換時(shí)間。
到此這篇關(guān)于詳細(xì)總結(jié)Java中常用的原子類的文章就介紹到這了,更多相關(guān)Java常用原子類內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
springboot中使用redis并且執(zhí)行調(diào)試lua腳本
今天有個(gè)項(xiàng)目需要使用redis，并且有使用腳本的需求，本文主要介紹了springboot中使用redis并且執(zhí)行調(diào)試lua腳本，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
elasticsearch+logstash并使用java代碼實(shí)現(xiàn)日志檢索
這篇文章主要介紹了elasticsearch+logstash并使用java代碼實(shí)現(xiàn)日志檢索,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-02-02
后端接口在接收數(shù)據(jù)的時(shí)候，都需要進(jìn)行檢查。檢查全部通過后，才能夠執(zhí)行業(yè)務(wù)邏輯。本文總結(jié)了四個(gè)Java檢查日期字符串是否合法的方法，感興趣的可以了解一下2022-10-10
Spring框架JdbcTemplate數(shù)據(jù)庫事務(wù)管理完全注解方式
這篇文章主要介紹了Spring框架JdbcTemplate數(shù)據(jù)庫事務(wù)管理及完全注解方式，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-05-05
這篇文章主要介紹了Java中的WeakHashMap簡析,Map 的子類常見的有 HashMap、Hashtable、ConcurrentHashMap、LinkedHashMap 等,WeakHashMap,直譯就是,虛弱的 HashMap,從名字可得知其和 HashMap 有關(guān),需要的朋友可以參考下2023-09-09
Springcloud hystrix服務(wù)熔斷和dashboard如何實(shí)現(xiàn)
這篇文章主要介紹了Springcloud hystrix服務(wù)熔斷和dashboard如何實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-12-12
SpringCloud OpenFeign 自定義響應(yīng)解碼器的問題記錄
我們?cè)谑褂?nbsp;Spring Cloud 微服務(wù)的時(shí)候,通常將返回結(jié)果使用一個(gè)JsonResult 類進(jìn)行封裝,本文重點(diǎn)介紹SpringCloud OpenFeign 自定義響應(yīng)解碼器的問題記錄,感興趣的朋友跟隨小編一起看看吧2024-06-06
我們知道在java連接數(shù)據(jù)庫之后,需要數(shù)據(jù)庫的sql語句,下面這篇文章主要給大家介紹了關(guān)于java中復(fù)雜查詢sql語句該怎么寫的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-11-11
本篇文章給大家介紹SpringMVC中處理Ajax請(qǐng)求的示例,本文通過示例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧2023-11-11
這篇文章主要介紹了spring @Transactional 無效的解決方案,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03