如何使用 Java Synchronization 实现公平锁

在Java中，可以使用java.util.concurrent.locks.ReentrantLock类实现公平锁

import java.util.concurrent.locks.ReentrantLock;

public class FairLockExample {
    private final ReentrantLock fairLock = new ReentrantLock(true); // 使用公平锁构造函数创建锁

    public void doSomething() {
        fairLock.lock(); // 获取锁
        try {
            // 临界区代码
            System.out.println(Thread.currentThread().getName() + " is in critical section.");
        } finally {
            fairLock.unlock(); // 释放锁
        }
    }

    public static void main(String[] args) {
        FairLockExample example = new FairLockExample();

        // 创建两个线程
        Thread thread1 = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                example.doSomething();
            }
        }, "Thread-1");

        Thread thread2 = new Thread(() -> {
            for (int i = 0; i < 5; i++) {
                example.doSomething();
            }
        }, "Thread-2");

        // 启动线程
        thread1.start();
        thread2.start();
    }
}

在这个示例中，我们创建了一个名为FairLockExample的类，它包含一个使用公平锁策略的ReentrantLock实例。当创建ReentrantLock对象时，我们将第二个参数设置为true，以启用公平锁策略。这意味着等待时间最长的线程将获得锁。

在doSomething方法中，我们使用fairLock.lock()获取锁，然后在finally块中使用fairLock.unlock()释放锁。这样可以确保锁在临界区代码执行完毕后被正确释放，避免死锁。

在main方法中，我们创建了两个线程并启动它们。由于我们使用了公平锁策略，因此等待时间最长的线程将获得锁，从而避免了线程饥饿问题。