BlockingQueue 是 Java 并發編程庫中的一個接口，它表示一個線程安全的阻塞隊列

在分布式鎖的實現中，BlockingQueue 可以用于存儲等待獲取鎖的線程。當一個線程嘗試獲取鎖時，如果鎖已經被其他線程持有，那么該線程會被放入 BlockingQueue 中等待。當鎖被釋放時，BlockingQueue 中的一個線程會被喚醒并嘗試獲取鎖。這樣，BlockingQueue 可以幫助實現公平的分布式鎖，因為它會按照線程進入隊列的順序來分配鎖。

下面是一個使用 BlockingQueue 實現分布式鎖的簡單示例：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;

public class DistributedLock implements Lock {
    private final BlockingQueue<Thread> queue = new LinkedBlockingQueue<>();

    @Override
    public void lock() {
        while (true) {
            try {
                if (queue.isEmpty() && queue.offer(Thread.currentThread(), 0, TimeUnit.MILLISECONDS)) {
                    return;
                } else {
                    Thread.sleep(100);
                }
            } catch (InterruptedException e) {
                // Handle exception
            }
        }
    }

    @Override
    public void unlock() {
        if (queue.peek() == Thread.currentThread()) {
            queue.poll();
        }
    }

    // Other methods like tryLock(), lockInterruptibly() and newCondition() are not implemented in this example
}

請注意，這個示例僅用于說明如何使用 BlockingQueue 實現分布式鎖的基本思想。在實際應用中，你需要考慮更多的細節，例如鎖的可重入性、鎖的公平性、鎖的可中斷性等。此外，這個示例沒有處理鎖的超時和中斷，這些功能在實際的分布式鎖實現中也是非常重要的。