当前位置：首页 > news >正文

Java的锁机制详解

news 2025/8/13 11:20:59

在并发编程中，锁是用于控制多个线程对共享资源进行访问的工具。Java提供了多种锁机制，从最基础的 synchronized 到高级的 ReentrantLock，这些锁帮助我们确保线程安全，并能有效避免数据竞争和死锁问题。
在这里插入图片描述

1. synchronized 关键字

synchronized 是Java中最简单的锁机制。它可以锁住方法或者代码块，确保某个线程在访问共享资源时，其他线程无法访问同一个资源。

示例代码：同步方法

public class SynchronizedExample {public synchronized void synchronizedMethod() {System.out.println("Thread " + Thread.currentThread().getName() + " is executing synchronized method.");}
}

在上述代码中，synchronizedMethod 方法被 synchronized 关键字修饰，意味着同一时间只能有一个线程执行该方法。

示例代码：同步代码块

public class SynchronizedBlockExample {private final Object lock = new Object();public void synchronizedBlock() {synchronized (lock) {System.out.println("Thread " + Thread.currentThread().getName() + " is executing synchronized block.");}}
}

使用同步代码块可以灵活地锁定某个对象（如上例中的 lock），只锁住需要保护的部分，而不是整个方法。

锁的粒度问题

synchronized 锁的粒度较粗，可能会导致性能瓶颈。对于更复杂的并发场景，ReentrantLock 等更灵活的锁机制是更好的选择。

2. ReentrantLock

ReentrantLock 是 Java java.util.concurrent.locks 包中的高级锁，它提供了更丰富的功能，如：公平锁、可重入性、可中断锁 等。

2.1 基本使用

import java.util.concurrent.locks.ReentrantLock;public class ReentrantLockExample {private final ReentrantLock lock = new ReentrantLock();public void execute() {lock.lock(); // 获取锁try {System.out.println("Thread " + Thread.currentThread().getName() + " is executing.");} finally {lock.unlock(); // 释放锁}}
}

在这个例子中，我们显式地调用 lock.lock() 来获取锁，并在 finally 中确保锁会被释放，以防止因异常导致死锁。

2.2 公平锁

默认情况下，ReentrantLock 是非公平锁，即等待时间长的线程不一定优先获得锁。你可以通过构造函数指定是否为公平锁：

ReentrantLock fairLock = new ReentrantLock(true); // 公平锁

公平锁确保先请求锁的线程先获得锁，但相对性能较低。

3. ReadWriteLock

ReadWriteLock 是一种更细粒度的锁，它允许多个读线程同时访问共享资源，但在有写操作时，写线程会独占资源。典型的实现是 ReentrantReadWriteLock。

示例代码

import java.util.concurrent.locks.ReentrantReadWriteLock;public class ReadWriteLockExample {private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();public void read() {rwLock.readLock().lock();try {System.out.println("Thread " + Thread.currentThread().getName() + " is reading.");} finally {rwLock.readLock().unlock();}}public void write() {rwLock.writeLock().lock();try {System.out.println("Thread " + Thread.currentThread().getName() + " is writing.");} finally {rwLock.writeLock().unlock();}}
}