精通Java并發：ReentrantLock原理、應用與優秀實踐

作者：迷路的架構師 2023-04-06 00:15:03

ReentrantLock是Java并發包（java.util.concurrent.locks）中的一個重要類，用于實現可重入的互斥鎖。它提供了一種替代synchronized關鍵字的同步機制，同時提供了更高級的同步功能，如可中斷的同步操作、帶超時的同步操作以及公平鎖策略。

一、ReentrantLock簡介

1.1 什么是ReentrantLock

1.2 ReentrantLock與synchronized的區別

ReentrantLock和synchronized都可以實現線程同步，但ReentrantLock具有更多的優勢：

ReentrantLock提供了更靈活的鎖控制，例如可中斷的鎖定操作和帶超時的鎖定操作。
ReentrantLock支持公平鎖策略，可選擇按照線程等待的順序分配鎖，而synchronized默認為非公平鎖。
ReentrantLock提供了更細粒度的鎖控制，可以獲取鎖的持有數量、查詢是否有等待線程等。
ReentrantLock可以顯式地加鎖和解鎖，而synchronized是隱式地加鎖和解鎖。

然而，ReentrantLock的手動解鎖風險需要特別關注，開發者需要確保在使用ReentrantLock時，始終在finally塊中釋放鎖。

1.3 ReentrantLock的可重入性和公平性策略

ReentrantLock具有可重入性，即一個線程在已經持有鎖的情況下，可以再次獲得同一個鎖，而不會產生死鎖。可重入性降低了死鎖的發生概率，簡化了多線程同步的實現。

ReentrantLock同時支持公平鎖和非公平鎖策略。公平鎖策略保證了等待時間最長的線程優先獲取鎖，從而減少了線程饑餓的可能性。然而，公平鎖可能導致性能損失，因此默認情況下，ReentrantLock使用非公平鎖策略。在實際應用中，應根據具體場景選擇合適的鎖策略。

二、ReentrantLock的核心方法

2.1 lock()和unlock()

lock()方法用于獲取鎖。如果鎖可用，則當前線程將獲得鎖。如果鎖不可用，則當前線程將進入等待隊列，直到鎖變為可用。當線程成功獲取鎖之后，需要在finally塊中調用unlock()方法釋放鎖，以確保其他線程可以獲取鎖。

2.2 tryLock()

tryLock()方法嘗試獲取鎖，但不會導致線程進入等待隊列。如果鎖可用，則立即獲取鎖并返回true。如果鎖不可用，則立即返回false，而不會等待鎖釋放。此方法可用于避免線程長時間等待鎖。

2.3 lockInterruptibly()

lockInterruptibly()方法與lock()方法類似，但它能夠響應中斷。如果線程在等待獲取鎖時被中斷，該方法將拋出InterruptedException。使用此方法可以實現可中斷的同步操作。

2.4 getHoldCount()

getHoldCount()方法返回當前線程對此鎖的持有計數。這對于可重入鎖的調試和診斷可能非常有用。

2.5 hasQueuedThreads()和getQueueLength()

hasQueuedThreads()方法檢查是否有線程正在等待獲取此鎖。getQueueLength()方法返回正在等待獲取此鎖的線程數。這兩個方法可以用于監控和診斷鎖的使用情況。

2.6 isHeldByCurrentThread()

isHeldByCurrentThread()方法檢查當前線程是否持有此鎖。這對于調試和驗證鎖狀態非常有用。

注意：這些方法在實際使用時需與try-catch-finally結構配合使用，確保鎖能夠正確釋放。

三、ReentrantLock的使用場景

3.1 替代synchronized實現同步

ReentrantLock可用于替代synchronized關鍵字實現線程同步。與synchronized相比，ReentrantLock提供了更靈活的鎖定策略和更細粒度的鎖控制。

3.2 實現可中斷的同步操作

ReentrantLock的lockInterruptibly()方法允許線程在等待鎖時響應中斷。這可以幫助避免死鎖或提前終止不再需要的操作。

3.3 實現帶超時的同步操作

ReentrantLock的tryLock(long timeout, TimeUnit unit)方法允許線程嘗試在指定的時間內獲取鎖。如果超過指定時間仍未獲取到鎖，則方法返回false。這可以幫助避免線程長時間等待鎖。

3.4 實現公平鎖的場景

ReentrantLock支持公平鎖策略，可以按照線程等待的順序分配鎖。在高并發場景下，公平鎖有助于減少線程饑餓的可能性。使用ReentrantLock構造函數的參數fair設置為true時，將使用公平鎖策略。

四、ReentrantLock的實戰應用

以下示例展示了如何使用ReentrantLock實現線程同步的一些實戰應用。

4.1 生產者-消費者模型

在生產者-消費者模型中，ReentrantLock可以確保生產者和消費者之間的同步。

import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class ProducerConsumerExample {
    private final Queue<Integer> buffer = new LinkedList<>();
    private final int capacity = 10;
    private final ReentrantLock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();
    private final Condition notEmpty = lock.newCondition();

    public void produce() {
        try {
            lock.lock();
            while (buffer.size() == capacity) {
                notFull.await();
            }
            buffer.add(1);
            System.out.println("Produced: " + 1);
            notEmpty.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }

    public void consume() {
        try {
            lock.lock();
            while (buffer.isEmpty()) {
                notEmpty.await();
            }
            int value = buffer.poll();
            System.out.println("Consumed: " + value);
            notFull.signalAll();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            lock.unlock();
        }
    }
}

4.2 實現可中斷的同步操作

以下示例展示了如何使用ReentrantLock實現可中斷的同步操作。

import java.util.concurrent.locks.ReentrantLock;

public class InterruptibleSynchronizationExample {
    private final ReentrantLock lock = new ReentrantLock();

    public void doInterruptibleWork() {
        try {
            lock.lockInterruptibly();
            try {
                // Perform some work
            } finally {
                lock.unlock();
            }
        } catch (InterruptedException e) {
            // Handle the interruption
        }
    }
}

4.3 實現帶超時的同步操作

以下示例展示了如何使用ReentrantLock實現帶超時的同步操作。

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

public class TimeoutSynchronizationExample {
    private final ReentrantLock lock = new ReentrantLock();

    public void doTimeoutWork() {
        try {
            if (lock.tryLock(5, TimeUnit.SECONDS)) {
                try {
                    // Perform some work
                } finally {
                    lock.unlock();
                }
            } else {
                System.out.println("Failed to acquire the lock within the timeout");
            }
        } catch (InterruptedException e) {
            // Handle the interruption
        }
    }
}

這些實戰應用展示了ReentrantLock如何在不同場景下實現線程同步，提高代碼的靈活性和可維護性。

五、ReentrantLock的局限性及替代方案

盡管ReentrantLock提供了相對于synchronized關鍵字更靈活的線程同步方法，但它仍具有一些局限性：

5.1 代碼復雜性

使用ReentrantLock時，需要手動調用lock()和unlock()方法，這可能增加了代碼的復雜性。此外，如果開發者在編寫代碼時遺漏了unlock()方法，可能導致其他線程無法獲取鎖，進而引發死鎖。

5.2 性能開銷

ReentrantLock實現了許多高級特性，如公平性和可中斷性。這些特性的實現可能會導致額外的性能開銷。在某些情況下，synchronized關鍵字可能提供更好的性能。

針對ReentrantLock的局限性，以下是一些替代方案：

5.3 Java并發包中的其他同步工具

Java并發包中還提供了其他同步工具，如Semaphore、CountDownLatch、CyclicBarrier和Phaser，可以根據不同場景選擇合適的同步工具。

5.4 使用Java并發包中的鎖接口

在某些情況下，可以使用Java并發包中的鎖接口（
java.util.concurrent.locks.Lock），而不是ReentrantLock。這使得在不同實現之間更容易切換，以便根據需要進行優化。

5.5 使用StampedLock

Java 8引入了一種新的鎖機制：StampedLock。與ReentrantLock相比，StampedLock通常具有更好的性能，特別是在高并發場景下。然而，使用StampedLock可能會增加代碼的復雜性，因為它需要在讀寫操作之間進行協調。

根據具體場景和需求，可以在ReentrantLock、synchronized關鍵字以及其他Java并發工具之間進行選擇。考慮到性能、靈活性和代碼復雜性等因素，選擇合適的同步工具將有助于提高程序的可維護性和性能。

六、ReentrantLock在實際項目中的最佳實踐

在實際項目中使用ReentrantLock時，遵循以下最佳實踐可以提高代碼的可讀性、可維護性和性能：

6.1 使用try-finally代碼塊確保鎖被釋放

為避免因異常或其他原因導致鎖未釋放，使用try-finally代碼塊確保在代碼執行完成后總是調用unlock()方法。

ReentrantLock lock = new ReentrantLock();
lock.lock();
try {
    // 臨界區代碼
} finally {
    lock.unlock();
}

6.2 優先考慮synchronized關鍵字

如果不需要ReentrantLock提供的高級特性（如可中斷鎖、帶超時的鎖定等），優先考慮使用synchronized關鍵字。這可以簡化代碼，降低出錯概率，并可能提高性能。

6.3 避免死鎖

在使用ReentrantLock時，避免死鎖是至關重要的。為防止死鎖，確保線程始終以固定的順序獲取鎖。此外，使用帶超時的鎖定方法（如tryLock()）可以防止線程無限期地等待鎖。

6.4 使用Condition對象進行線程間協作

當需要在線程間實現更復雜的同步時，可以使用ReentrantLock關聯的Condition對象。Condition對象提供了類似于Object.wait()和Object.notify()的方法，允許線程在特定條件下等待和喚醒。這有助于避免不必要的輪詢和資源浪費。

ReentrantLock lock = new ReentrantLock();
Condition condition = lock.newCondition();

// 等待特定條件
lock.lock();
try {
    while (!conditionSatisfied()) {
        condition.await();
    }
    // 執行操作
} catch (InterruptedException e) {
    // 處理中斷異常
} finally {
    lock.unlock();
}

// 喚醒等待條件的線程
lock.lock();
try {
    // 更改狀態
    condition.signalAll();
} finally {
    lock.unlock();
}

6.5 使用公平鎖避免線程饑餓

在創建ReentrantLock實例時，可以選擇公平鎖策略。公平鎖確保等待時間最長的線程優先獲得鎖。雖然公平鎖可能導致性能下降，但它可以避免線程饑餓。根據具體需求和性能要求，可以選擇是否使用公平鎖。

ReentrantLock fairLock = new ReentrantLock(true); // 公平鎖
ReentrantLock nonFairLock = new ReentrantLock(); // 默認非公平鎖

6.6 選擇合適的鎖粒度

在使用ReentrantLock時，應找到合適的鎖粒度。鎖定整個對象可能會導致性能下降和線程阻塞。如果可能，嘗試鎖定較小的臨界區，以提高并發性能。

責任編輯：華軒來源：今日頭條