Java并发工具：Lock锁的多线程问题实例

原创我不是女神ヾ 2024-11-22 13:39 14阅读 0赞

在Java多线程编程中，Lock锁是非常重要的同步工具。当涉及到多个线程共享资源的问题时，锁就起到了保护和控制访问的作用。

下面是一个使用Lock锁解决多线程读写问题的实例：

```java
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

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

public void read() throws InterruptedException {
        lock.acquire(); // 请求锁
        System.out.println("Thread " + Thread.currentThread().getId() + " is reading data ...");
        lock.release(); // 释放锁
    }

public void write() throws InterruptedException {
        lock.acquire(); // 请求锁
        System.out.println("Thread " + Thread.currentThread().getId() + " is writing data ...");
        // 在写入操作完成后，自己释放锁
        // 这是因为，一旦进入写操作，就可能需要阻塞一段时间，
        // 如果此时锁被其他线程获取了，那么这个线程将会被阻塞，
        // 造成死锁。所以，写操作完成后，必须自己释放锁。

lock.release(); // 释放锁
    }

public static void main(String[] args) {
        LockExample example = new LockExample();
        Thread readerThread = new Thread(() -> example.read()));
        Thread writerThread = new Thread(() -> example.write()));

readerThread.start();
        writerThread.start();

try {
            readerThread.join();
            writerThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，我们创建了一个Lock锁和一个读写操作的线程。在read操作中，线程请求锁并执行读取操作；在write操作中，线程同样请求锁并执行写入操作。

为了防止死锁，我们在写操作完成后手动释放锁，这确保了后续线程能够正确地获取和释放锁。