目錄
1. synchronized:最原始但依然高效的同步機制
優點:
缺點:
2. 顯式鎖(Lock):更靈活的控制
主要優勢:
使用建議
3. 無鎖(Lock-Free)算法:基於CAS 的非阻塞並發
CAS 原理:
示例:原子整數計數器
CAS 的ABA 問題
4. 高級Lock-Free 數據結構
1. ConcurrentLinkedQueue
2. AtomicIntegerFieldUpdater / AtomicReferenceFieldUpdater
3. LongAdder vs AtomicLong
5. 實現一個簡單的Lock-Free 棧(無鎖棧)
總結:從synchronized 到Lock-Free 的演進邏輯
首頁 Java java教程 高級Java多線程:從同步到無鎖算法

高級Java多線程:從同步到無鎖算法

Jul 27, 2025 am 01:13 AM

synchronized是Java最早的同步機制,簡單易用且經優化後性能良好,但缺乏靈活性;2. ReentrantLock提供可中斷、可重入、支持公平性等高級功能,適用於需精細控制的場景;3. 無鎖算法基於CAS實現非阻塞並發,如AtomicLong、LongAdder和ConcurrentLinkedQueue,在高競爭環境下性能更優,但需處理ABA問題和CPU自旋開銷;最終應根據並發強度選擇合適策略:低競爭用synchronized,需控制用ReentrantLock,高並發場景用無鎖結構,從而實現從基礎同步到高性能並發的演進。

Advanced Java Multithreading: from synchronized to Lock-Free Algorithms

Java 的多線程編程從早期的synchronized關鍵字,逐步演進到更靈活的Lock框架,再到如今高性能場景下廣泛使用的無鎖(Lock-Free)算法。掌握這一演進路徑,不僅有助於寫出更高效的並發程序,也能深入理解現代JVM 和硬件層面的並發機制。

Advanced Java Multithreading: from synchronized to Lock-Free Algorithms

下面從三個層次來解析: synchronized → 顯式鎖( ReentrantLock ) → 無鎖算法(Lock-Free),帶你從基礎走向高級。


1. synchronized:最原始但依然高效的同步機制

synchronized是Java 最早提供的線程同步關鍵字,可用於方法或代碼塊,確保同一時刻只有一個線程能進入臨界區。

Advanced Java Multithreading: from synchronized to Lock-Free Algorithms
 public synchronized void increment() {
    count ;
}

優點:

  • 簡單易用,JVM 自動管理鎖的獲取與釋放。
  • 在JDK 1.6 之後經過大量優化(偏向鎖、輕量級鎖、鎖膨脹等),性能已大幅提升。

缺點:

  • 不可中斷,線程阻塞時無法響應中斷。
  • 無法嘗試加鎖(沒有tryLock)。
  • 不支持公平性控制。
  • 鎖粒度較粗,靈活性差。

儘管如此,在大多數普通並發場景中, synchronized依然是首選,因為它的性能已經非常接近顯式鎖,且不易出錯。


2. 顯式鎖(Lock):更靈活的控制

Java 5 引入了java.util.concurrent.locks.Lock接口,最常用的是ReentrantLock ,它提供了比synchronized更豐富的功能。

Advanced Java Multithreading: from synchronized to Lock-Free Algorithms
 private final ReentrantLock lock = new ReentrantLock();

public void increment() {
    lock.lock();
    try {
        count ;
    } finally {
        lock.unlock();
    }
}

主要優勢:

  • 支持可中斷的鎖獲取lockInterruptibly()
  • 支持嘗試加鎖tryLock() ),避免無限等待
  • 支持公平鎖(構造時傳入true ),減少線程飢餓
  • 更細粒度的Condition控制( Condition )

使用建議:

  • 當你需要超時嘗試、中斷響應或公平性時,使用ReentrantLock
  • 必須配合try-finally使用,否則容易發生死鎖。

但注意:顯式鎖依然是“阻塞式”的,線程拿不到鎖就會被掛起,上下文切換帶來開銷。


3. 無鎖(Lock-Free)算法:基於CAS 的非阻塞並發

真正的高性能並發,尤其是在高競爭場景(如高頻交易、高並發計數器、無鎖隊列),需要擺脫“鎖”的概念,轉向Lock-FreeWait-Free算法。

其核心是CAS(Compare-And-Swap)操作,由Unsafe類提供,Java 中通過java.util.concurrent.atomic包封裝。

CAS 原理:

 // 偽代碼:僅噹噹前值等於expect 時,才更新為update
boolean compareAndSet(int expect, int update);

示例:原子整數計數器

private final AtomicLong counter = new AtomicLong(0);

public void increment() {
    counter.incrementAndGet(); // 內部基於CAS 循環}

CAS 的ABA 問題

CAS 只比較值是否相等,不關心中間是否被修改過。例如:

  • 線程1讀取值A
  • 線程2 將A → B → A
  • 線程1 執行CAS(A, new_value),成功,但中間狀態已被篡改

解決方案:使用AtomicStampedReference ,引入版本號(時間戳)來區分真實變化。

 AtomicStampedReference<Integer> ref = new AtomicStampedReference<>(100, 0);

int stamp = ref.getStamp();
Integer value = ref.getReference();
if (ref.compareAndSet(value, newValue, stamp, stamp 1)) {
    // 成功更新}

4. 高級Lock-Free 數據結構

JDK 提供了一些基於無鎖算法的高性能容器:

1. ConcurrentLinkedQueue

  • 無鎖的線程安全隊列
  • 基於CAS 實現offer()poll()
  • 適合高並發生產者-消費者場景

2. AtomicIntegerFieldUpdater / AtomicReferenceFieldUpdater

  • 可以對普通對象的volatile字段進行原子操作
  • 避免為每個字段創建AtomicInteger對象,節省內存
public class Task {
    volatile int state;
    static final AtomicIntegerFieldUpdater<Task> updater =
        AtomicIntegerFieldUpdater.newUpdater(Task.class, "state");

    public boolean setStateIf(int expected, int newValue) {
        return updater.compareAndSet(this, expected, newValue);
    }
}

3. LongAdder vs AtomicLong

  • 在高並發累加場景下, LongAdder性能遠超AtomicLong
  • 原理:分段累加(類似ConcurrentHashMap 的分段鎖思想),最後匯總
private final LongAdder adder = new LongAdder();

public void increment() {
    adder.increment(); // 高並發下衝突更少}

public long getTotal() {
    return adder.sum(); // 匯總所有段的值}

5. 實現一個簡單的Lock-Free 棧(無鎖棧)

 public class LockFreeStack<T> {
    private final AtomicReference<Node<T>> top = new AtomicReference<>();

    private static class Node<T> {
        final T value;
        final Node<T> next;

        Node(T value, Node<T> next) {
            this.value = value;
            this.next = next;
        }
    }

    public void push(T value) {
        Node<T> newHead = new Node<>(value, null);
        Node<T> currentHead;
        do {
            currentHead = top.get();
            newHead = new Node<>(value, currentHead);
        } while (!top.compareAndSet(currentHead, newHead));
    }

    public T pop() {
        Node<T> currentHead;
        Node<T> newHead;
        do {
            currentHead = top.get();
            if (currentHead == null) return null;
            newHead = currentHead.next;
        } while (!top.compareAndSet(currentHead, newHead));
        return currentHead.value;
    }
}

這個棧使用AtomicReference和CAS 實現push/pop,全程無鎖,但需注意:

  • 循環重試(spin)可能消耗CPU
  • 不適合長時間操作

總結:從synchronized 到Lock-Free 的演進邏輯

特性 synchronized ReentrantLock Lock-Free
易用性 ⭐⭐⭐⭐⭐ ⭐⭐⭐⭐ ⭐⭐
性能(低競爭) 極高
性能(高競爭) 下降明顯 下降明顯 依然高效
可中斷 ✅(非阻塞)
公平性 N/A
ABA 問題 不適用 不適用 需處理

使用建議

  • 普通場景優先用synchronized ,足夠快且安全。
  • 需要超時、中斷、公平性時用ReentrantLock
  • 高並發計數、狀態更新用AtomicXXXLongAdder
  • 構建高性能隊列、棧等結構時,考慮ConcurrentLinkedQueue或手寫CAS 結構。
  • 注意:無鎖≠ 無代價,CAS 失敗重試可能帶來CPU 浪費,需結合場景評估。

基本上就這些。掌握這些層次,你就能在不同並發強度下選擇最合適的同步策略,從“會用鎖”走向“懂並發”。

以上是高級Java多線程:從同步到無鎖算法的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

Rimworld Odyssey溫度指南和Gravtech
1 個月前 By Jack chen
初學者的Rimworld指南:奧德賽
1 個月前 By Jack chen
PHP變量範圍解釋了
4 週前 By 百草
撰寫PHP評論的提示
3 週前 By 百草
在PHP中評論代碼
3 週前 By 百草

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Laravel 教程
1604
29
PHP教程
1509
276
Hashmap在Java內部如何工作? Hashmap在Java內部如何工作? Jul 15, 2025 am 03:10 AM

HashMap在Java中通過哈希表實現鍵值對存儲,其核心在於快速定位數據位置。 1.首先使用鍵的hashCode()方法生成哈希值,並通過位運算轉換為數組索引;2.不同對象可能產生相同哈希值,導致衝突,此時以鍊錶形式掛載節點,JDK8後鍊錶過長(默認長度8)則轉為紅黑樹提升效率;3.使用自定義類作鍵時必須重寫equals()和hashCode()方法;4.HashMap動態擴容,當元素數超過容量乘以負載因子(默認0.75)時,擴容並重新哈希;5.HashMap非線程安全,多線程下應使用Concu

如何在Windows中設置Java_home環境變量 如何在Windows中設置Java_home環境變量 Jul 18, 2025 am 04:05 AM

tosetjava_homeonwindows,firstLocateThejDkinStallationPath(例如,C:\ programFiles \ java \ jdk-17),tencreateasyemystemenvironmentvaria blenamedjava_homewiththatpath.next,updateThepathvariaby byadding%java \ _home%\ bin,andverifyTheSetupusingjava-versionAndjavac-v

Java虛擬線程性能基準測試 Java虛擬線程性能基準測試 Jul 21, 2025 am 03:17 AM

虚拟线程在高并发、IO密集型场景下性能优势显著,但需注意测试方法与适用场景。1.正确测试应模拟真实业务尤其是IO阻塞场景,使用JMH或Gatling等工具对比平台线程;2.吞吐量差距明显,在10万并发请求下可高出几倍至十几倍,因其更轻量、调度高效;3.测试中需避免盲目追求高并发数,适配非阻塞IO模型,并关注延迟、GC等监控指标;4.实际应用中适用于Web后端、异步任务处理及大量并发IO场景,而CPU密集型任务仍适合平台线程或ForkJoinPool。

如何使用JDBC處理Java的交易? 如何使用JDBC處理Java的交易? Aug 02, 2025 pm 12:29 PM

要正確處理JDBC事務,必須先關閉自動提交模式,再執行多個操作,最後根據結果提交或回滾;1.調用conn.setAutoCommit(false)以開始事務;2.執行多個SQL操作,如INSERT和UPDATE;3.若所有操作成功則調用conn.commit(),若發生異常則調用conn.rollback()確保數據一致性;同時應使用try-with-resources管理資源,妥善處理異常並關閉連接,避免連接洩漏;此外建議使用連接池、設置保存點實現部分回滾,並保持事務盡可能短以提升性能。

在Java中實現鏈接列表 在Java中實現鏈接列表 Jul 20, 2025 am 03:31 AM

實現鍊錶的關鍵在於定義節點類並實現基本操作。 ①首先創建Node類,包含數據和指向下一個節點的引用;②接著創建LinkedList類,實現插入、刪除和打印功能;③append方法用於在尾部添加節點;④printList方法用於輸出鍊錶內容;⑤deleteWithValue方法用於刪除指定值的節點,處理頭節點和中間節點的不同情況。

Java微服務服務網格集成 Java微服務服務網格集成 Jul 21, 2025 am 03:16 AM

ServiceMesh是Java微服務架構演進的必然選擇,其核心在於解耦網絡邏輯與業務代碼。 1.ServiceMesh通過Sidecar代理處理負載均衡、熔斷、監控等功能,使開發聚焦業務;2.Istio Envoy適合中大型項目,Linkerd更輕量適合小規模試水;3.Java微服務應關閉Feign、Ribbon等組件,交由Istiod管理服務發現與通信;4.部署時確保Sidecar自動注入,注意流量規則配置、協議兼容性、日誌追踪體系建設,並採用漸進式遷移和前置化監控規劃。

如何使用SimpleDateFormat在Java中格式化日期? 如何使用SimpleDateFormat在Java中格式化日期? Jul 15, 2025 am 03:12 AM

創建並使用SimpleDateFormat需要傳入格式字符串,如newSimpleDateFormat("yyyy-MM-ddHH:mm:ss");2.注意大小寫敏感、避免混用單字母格式及YYYY和DD的誤用;3.SimpleDateFormat不是線程安全的,多線程環境下應每次新建實例或使用ThreadLocal;4.使用parse方法解析字符串時需捕獲ParseException,並註意結果不帶時區信息;5.Java8及以上推薦使用DateTimeFormatter和Lo

高級Java收集框架優化 高級Java收集框架優化 Jul 20, 2025 am 03:48 AM

为提升Java集合框架性能,可从以下四点优化:1.根据场景选择合适类型,如频繁随机访问用ArrayList、快速查找用HashSet、并发环境用ConcurrentHashMap;2.初始化时合理设置容量和负载因子以减少扩容开销,但避免内存浪费;3.使用不可变集合(如List.of())提高安全性与性能,适用于常量或只读数据;4.防止内存泄漏,使用弱引用或专业缓存库管理长期存活的集合。这些细节显著影响程序稳定性与效率。

See all articles