Java多線程同步的幾種常見方法
Java多線程同步有哪些方法?
1. 使用 synchronized 關(guān)鍵字
synchronized 是 Java 提供的最基本的同步方式，它可以用來修飾方法或代碼塊，確保同一時刻只有一個線程能夠執(zhí)行被同步的代碼部分。
(1) 同步方法
將整個方法標記為同步方法，確保同一時刻只有一個線程能夠執(zhí)行該方法。
public synchronized void method() {
// 線程安全的操作
}- 如果同步方法是實例方法，鎖是當前實例對象（
this）。 - 如果同步方法是靜態(tài)方法，鎖是類對象（
Class）。
(2) 同步代碼塊
通過同步代碼塊，指定一個特定的鎖對象來控制同步的范圍，從而提高性能。
public void method() {
synchronized (this) {
// 線程安全的操作
}
}this 表示鎖住當前實例對象，可以根據(jù)需要使用不同的鎖對象。
2. 使用 ReentrantLock
ReentrantLock 是 java.util.concurrent.locks 包中的一個鎖實現(xiàn)，提供比 synchronized 更加靈活和強大的功能，如可重入性、公平性、響應(yīng)中斷等。通過顯式調(diào)用 lock() 和 unlock() 來控制鎖的獲取和釋放。
import java.util.concurrent.locks.ReentrantLock;
public class LockExample {
private final ReentrantLock lock = new ReentrantLock();
public void method() {
lock.lock();
try {
// 線程安全的操作
} finally {
lock.unlock();
}
}
}特性：
- 可重入性：同一線程可以多次獲得鎖。
- 公平性：可以選擇公平鎖（按請求順序獲取鎖）。
- 中斷響應(yīng)：支持響應(yīng)線程中斷。
3. 使用 ReadWriteLock
ReadWriteLock 是 java.util.concurrent.locks 包中的一個接口，分為 ReentrantReadWriteLock 實現(xiàn)類。它提供了讀寫鎖機制，其中允許多個線程同時讀，但寫操作是互斥的，保證了高效的讀操作并避免寫操作沖突。
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class ReadWriteLockExample {
private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
public void readMethod() {
lock.readLock().lock();
try {
// 線程安全的讀操作
} finally {
lock.readLock().unlock();
}
}
public void writeMethod() {
lock.writeLock().lock();
try {
// 線程安全的寫操作
} finally {
lock.writeLock().unlock();
}
}
}特性：
- 讀鎖：多個線程可以同時獲得讀鎖，只要沒有寫鎖被占用。
- 寫鎖：寫鎖是獨占的，當一個線程獲取寫鎖時，其他線程不能同時獲得讀鎖或?qū)戞i。
4. 使用 volatile 關(guān)鍵字
volatile 關(guān)鍵字用于確保線程對某個變量的修改對其他線程立即可見。volatile 保證了變量的可見性，但并不能保證原子性。
private volatile boolean flag = false;
- 可見性：確保線程對
volatile變量的修改立即對其他線程可見。 - 不保證原子性：對于復(fù)合操作（如
i++），volatile并不能保證原子性。
5. 使用 Atomic 類
java.util.concurrent.atomic 包提供了一些原子操作類，如 AtomicInteger、AtomicBoolean 等，適用于處理簡單的數(shù)值操作。它們通過 CAS（比較并交換）機制提供原子操作，避免了使用鎖。
import java.util.concurrent.atomic.AtomicInteger;
public class AtomicExample {
private final AtomicInteger count = new AtomicInteger(0);
public void increment() {
count.incrementAndGet();
}
public int getCount() {
return count.get();
}
}- 原子性：這些類通過底層的 CAS 操作保證線程安全。
- 無鎖機制：避免了傳統(tǒng)鎖的性能開銷。
6. 使用 Semaphore（信號量）
Semaphore 是一種用來控制同時訪問特定資源的線程數(shù)的同步工具。它可以設(shè)置一個信號量計數(shù)，控制可以訪問某些資源的線程數(shù)量。
import java.util.concurrent.Semaphore;
public class SemaphoreExample {
private final Semaphore semaphore = new Semaphore(3); // 最大允許3個線程
public void accessResource() {
try {
semaphore.acquire();
// 執(zhí)行資源訪問操作
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
semaphore.release();
}
}
}- 可控制并發(fā)數(shù)：通過信號量來控制并發(fā)線程數(shù)。
- 適用場景：用于限制某些共享資源的并發(fā)訪問，例如數(shù)據(jù)庫連接池等。
7. 使用 CountDownLatch
CountDownLatch 是一種同步工具，允許一個或多個線程等待，直到其他線程完成一組操作后再繼續(xù)執(zhí)行。通常用于在一組線程完成任務(wù)后再啟動主線程或其他線程。
import java.util.concurrent.CountDownLatch;
public class CountDownLatchExample {
private final CountDownLatch latch = new CountDownLatch(3); // 等待3個線程完成
public void task() {
try {
// 執(zhí)行某些操作
} finally {
latch.countDown(); // 操作完成，計數(shù)減一
}
}
public void mainTask() throws InterruptedException {
latch.await(); // 等待所有線程完成
System.out.println("All tasks are finished!");
}
}8. 使用 CyclicBarrier
CyclicBarrier 是一個允許一組線程互相等待，直到所有線程都到達某個公共屏障點后再繼續(xù)執(zhí)行的同步工具。它適用于需要多線程并行執(zhí)行的場景。
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierExample {
private final CyclicBarrier barrier = new CyclicBarrier(3, new Runnable() {
@Override
public void run() {
System.out.println("All threads reached the barrier, continue execution.");
}
});
public void task() throws InterruptedException {
barrier.await(); // 等待所有線程到達屏障
// 執(zhí)行任務(wù)
}
}總結(jié)
Java 提供了多種同步機制來保證多線程環(huán)境下的線程安全，具體使用哪種方法，取決于實際的應(yīng)用場景：
synchronized：簡單易用，但性能較低。ReentrantLock：提供更靈活的鎖控制。ReadWriteLock：適用于讀多寫少的場景。volatile：用于保證變量的可見性，但不適用于復(fù)合操作。Atomic類：適用于簡單的原子操作，避免了鎖的使用。Semaphore：控制并發(fā)線程數(shù)量。CountDownLatch和CyclicBarrier：用于線程間協(xié)調(diào)與同步。
這些方法都可以在不同的場景下幫助我們實現(xiàn)線程安全與高效的并發(fā)控制。
以上就是Java多線程同步的幾種常見方法的詳細內(nèi)容，更多關(guān)于Java多線程同步方法的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
JVM優(yōu)先級線程池做任務(wù)隊列的實現(xiàn)方法
這篇文章主要介紹了JVM優(yōu)先級線程池做任務(wù)隊列的實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值，需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧2020-08-08
這篇文章主要是Maven基礎(chǔ)知識大梳理，Maven主要是用來解決導(dǎo)入java類依賴的jar,編譯java項目主要問題，大家可以讀一讀這篇文章，更深一步的了解Maven2021-08-08
這篇文章主要介紹了java使用枚舉封裝錯誤碼及錯誤信息，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
這篇文章主要介紹了intellij idea 將模塊打jar包的步驟，本文圖文并茂給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下2018-09-09
Spring?MVC基于注解的使用之JSON數(shù)據(jù)處理的方法
這篇文章主要介紹了Spring?MVC基于注解的使用JSON數(shù)據(jù)處理,json是一種輕量級的數(shù)據(jù)交換格式，是一種理想的數(shù)據(jù)交互語言，它易于閱讀和編寫，同時也易于機器解析和生成，本文通過實例代碼給大家介紹的非常詳細，需要的朋友可以參考下2022-05-05
這篇文章主要為大家詳細介紹了java連接mysql數(shù)據(jù)庫的方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
這篇文章主要介紹了JAVA 反射機制的相關(guān)知識，文中講解的非常細致，代碼幫助大家更好的理解學(xué)習，感興趣的朋友可以了解下，希望能給你帶來幫助2021-08-08
SpringBoot?SpringSecurity?詳細介紹(基于內(nèi)存的驗證)
這篇文章主要介紹了SpringBoot?SpringSecurity?介紹（基于內(nèi)存的驗證）,本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-04-04
這篇文章主要介紹了Spring Boot如何整合FreeMarker模板引擎,文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值,需要的朋友可以參考下2020-10-10
這篇文章主要介紹了Java包含抽象方法的枚舉類,結(jié)合實例形式分析了Java包含抽象方法的枚舉類實現(xiàn)方法與相關(guān)操作技巧,需要的朋友可以參考下2019-08-08