答案:Java中Lock接口(如ReentrantLock)相比synchronized提供更灵活的显式锁控制,支持非阻塞获取、限时等待、可中断及多条件变量,适用于复杂并发场景。
在Java多线程编程中,当我们需要对共享资源进行访问控制,避免数据不一致时,同步机制是不可或缺的。
Lock接口,特别是其最常用的实现
ReentrantLock,提供了一种比
synchronized关键字更灵活、更细粒度的同步控制方式。它让开发者能显式地管理锁的获取与释放,从而应对更复杂的并发场景。
在Java中使用
Lock接口实现同步,核心在于显式地获取和释放锁。这与
synchronized关键字的隐式锁管理形成了鲜明对比。通常,我们会使用
ReentrantLock这个
Lock接口的实现类。
基本的使用模式如下:
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class SharedResource {
private int count = 0;
private final Lock lock = new ReentrantLock(); // 实例化一个可重入锁
public void increment() {
lock.lock(); // 显式获取锁
try {
// 这是受保护的临界区
// 只有获取到锁的线程才能执行这里的代码
count++;
System.out.println(Thread.currentThread().getName() + " incremented count to: " + count);
} finally {
lock.unlock(); // 显式释放锁,这至关重要,必须放在finally块中
}
}
public int getCount() {
// 对于只读操作,如果其本身是原子性的,或者不涉及写操作,
// 且对数据一致性要求不是绝对实时,可以考虑不加锁。
// 但如果需要确保读取到最新、最一致的数据,或者读取过程复杂,
// 仍然建议加锁,或者使用ReadWriteLock。
lock.lock();
try {
return count;
} finally {
lock.unlock();
}
}
public static void main(String[] args) {
SharedResource resource = new SharedResource();
Runnable task = () -> {
for (int i = 0; i < 1000; i++) {
resource.increment();
}
};
Thread t1 = new Thread(task, "Thread-1");
Thread t2 = new Thread(task, "Thread-2");
t1.start();
t2.start();
try {
t1.join();
t2.join();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
System.out.println("Final count: " + resource.getCount());
}
}在这个例子中,
lock.lock()方法会阻塞当前线程,直到获取到锁为止。
lock.unlock()方法则用于释放锁。将
unlock()方法放在
finally块中是最佳实践,这确保了无论临界区代码是否抛出异常,锁都能被正确释放,避免死锁的发生。
Lock接口还提供了其他一些高级特性,比如:
tryLock():尝试获取锁,如果锁当前不可用,则立即返回
false,不会阻塞。这对于避免死锁或实现更灵活的并发策略非常有用。
tryLock(long timeout, TimeUnit unit):在指定时间内尝试获取锁,如果超时仍未获取到,则返回
false。
lockInterruptibly():获取锁,但如果当前线程在等待锁的过程中被中断,则会抛出
InterruptedException。这为响应中断提供了可能。
newCondition():返回一个
Condition实例,可以实现更复杂的等待/通知机制,类似于
Object的
wait()、
notify()和
notifyAll()。一个
Lock对象可以关联多个
Condition对象,这在某些场景下提供了极大的灵活性。
synchronized关键字后,我们还需要
Lock接口?
这确实是一个常被问到的问题。毕竟,
synchronized用起来多方便,直接加个关键字就行了。但深入一点看,
synchronized虽然简单,却有一些固有的局限性,这些局限性在复杂的并发场景下会显得力不从心。
synchronized关键字提供的是一种隐式的锁管理。当一个线程进入
synchronized方法或代码块时,它会自动获取对象的监视器锁;当退出时,锁会自动释放。这种“自动化”在很多情况下是好事,因为它减少了出错的可能性。然而,它的缺点也显而易见:
synchronized只能阻塞式地获取锁。如果锁被其他线程持有,当前线程就只能傻等,直到锁被释放。但在某些场景下,我们可能希望“如果能拿到锁就做,拿不到就先干点别的”,比如避免死锁或提高用户界面的响应速度。
synchronized不支持在指定时间内尝试获取锁。
synchronized块的等待状态,就无法被中断,它会一直等到锁被释放。这在需要快速响应中断的长时间操作中是个问题。
synchronized依赖于
Object的
wait()、
notify()和
notifyAll()方法,这些方法是与每个对象唯一的监视器锁绑定的。这意味着一个对象只有一个“等待队列”,所有等待该对象锁的线程都在同一个队列里。如果需要区分不同条件下的等待线程,
synchronized就显得力不从心了。
synchronized锁的获取是“不公平”的,即等待时间最长的线程不一定优先获得锁。这可能导致某些线程“饿死”(starvation)。
而
Lock接口,特别是
ReentrantLock,就是为了弥补这些不足而设计的。它提供了:
lock()和
unlock()方法,开发者可以精确控制锁的获取和释放时机。
tryLock()和
tryLock(long timeout, TimeUnit unit)方法允许线程尝试获取锁,而不会无限期阻塞,或者只在特定时间内等待。
lockInterruptibly()方法允许在线程等待锁的过程中响应中断。
Lock的
newCondition()方法,可以创建多个
Condition对象,每个
Condition都拥有自己独立的等待队列,从而实现更精细的等待/通知机制。这在生产者-消费者模型中,如果需要区分“缓冲区满”和“缓冲区空”两种等待状态时,非常有用。
ReentrantLock的构造函数允许你指定锁是否是“公平”的(
new ReentrantLock(true)),公平锁会优先将锁授予等待时间最长的线程,尽管这通常会带来一些性能开销。
所以,当我们面对需要更精细控制、避免死锁、提高响应性或实现复杂线程协作模式的场景时,
Lock接口就成了比
synchronized更合适的选择。它提供了一套更强大的工具集,让我们能更好地驾驭并发编程的复杂性。
ReentrantLock时有哪些常见的陷阱和最佳实践?
ReentrantLock虽然功能强大,但由于其显式管理的特性,也带来了一些需要特别注意的地方。一个不小心,就可能引入新的并发问题。
常见的陷阱:
lock()但没有在
finally块中调用
unlock(),那么一旦临界区代码抛出异常,锁将永远不会被释放。这将导致其他所有尝试获取该锁的线程永久阻塞,造成死锁或程序“假死”。
lock.lock();
// 临界区代码
if (someCondition) {
throw new RuntimeException("Oops!"); // 异常抛出,unlock()未执行
}
lock.unlock(); // 永远不会执行unlock():虽然
ReentrantLock会抛出
IllegalMonitorStateException,但这种情况通常意味着逻辑错误。锁的释放必须由持有该锁的线程来完成。
new ReentrantLock(true)创建的是公平锁,它会保证等待时间最长的线程优先获得锁,以避免饥饿。然而,公平锁通常比非公平锁的性能要差,因为它需要维护一个等待队列,并进行额外的上下文切换。在大多数情况下,如果不是有严格的公平性要求,非公平锁(默认)是更好的选择。
Condition:
Condition是与
Lock配合使用的等待/通知机制。如果不在持有锁的情况下调用
Condition的
await()、
signal()或`
signalAll()方法,会抛出
IllegalMonitorStateException。
最佳实践:
finally块中释放锁:这是最重要的原则。确保
lock.unlock()被放置在
try-finally结构中的
finally块里,以保证锁总能被释放。
lock.lock();
try {
// 临界区代码
} finally {
lock.unlock(); // 关键!
}tryLock()避免死锁和提高响应性:当一个线程需要同时获取多个锁时,使用
tryLock()(或带超时参数的
tryLock())可以避免死锁。如果无法一次性获取所有锁,就释放已获取的锁,然后等待一段时间再重试。这比简单的阻塞等待更健壮。
Condition:当需要实现复杂的线程协作,比如生产者-消费者模型中,根据不同条件(缓冲区满/空)唤醒特定线程组时,
Condition是
Object.wait/notify的强大替代品。记住,
await()、
signal()等方法必须在持有锁的情况下调用。
lock()和
unlock()之间。减少锁的持有时间可以显著提高并发性能。
lockInterruptibly():对于可能长时间等待锁的线程,如果允许它们在等待过程中被中断,那么使用
lockInterruptibly()是一个好选择。这样可以使程序更具响应性,例如在用户取消操作时。
ReentrantLock是可重入的,这意味着持有锁的线程可以再次获取该锁而不会死锁。这对于递归调用或内部方法也需要获取相同锁的情况非常有用。但也要注意,每次
lock()都必须对应一次
unlock(),否则锁无法完全释放。
遵循这些最佳实践,可以帮助我们更安全、高效地使用
ReentrantLock,从而构建出健壮的并发应用。
Lock接口与
synchronized关键字在性能上有什么差异?
关于
Lock接口(特别是
ReentrantLock)和
synchronized关键字的性能差异,这是一个经常被讨论的话题,但答案并非一成不变,它受到多种因素的影响,包括Java版本、JVM实现、硬件环境以及具体的代码场景。
历史背景与早期认知: 在Java早期版本中,
synchronized关键字的实现相对“笨重”,涉及重量级操作,如操作系统级别的互斥量。这使得
ReentrantLock(作为Java并发包J.U.C的一部分)在许多情况下被认为具有更好的性能,因为它通常使用更轻量级的机制(如CAS操作)来实现锁,并且提供了更灵活的控制,有助于减少锁的竞争。
现代JVM的优化: 然而,现代JVM(尤其是HotSpot JVM)对
synchronized关键字进行了大量的优化,使其性能得到了显著提升。这些优化包括:
当前的性能对比:
synchronized关键字的性能可能与
ReentrantLock相当,甚至在某些情况下略优。现代JVM的优化使得
synchronized的开销非常小,尤其是在偏向锁和轻量级锁生效时。
ReentrantLock虽然底层也使用CAS,但其API调用本身(如方法调用、对象创建)会带来一定的额外开销。
ReentrantLock可能会展现出更好的性能优势。这主要得益于它提供了更灵活的控制,例如
tryLock()和
lockInterruptibly(),这些功能可以帮助开发者编写更智能的并发代码,减少不必要的阻塞和上下文切换,从而在整体上提高系统的吞吐量和响应性。此外,
ReentrantLock可以选择公平性,虽然公平锁本身有性能开销,但在避免线程饥饿、优化特定业务逻辑时,这种控制能力可能间接带来更好的整体性能。
ReentrantLock提供的
Condition机制允许更细粒度的等待/通知,可以避免
synchronized的
wait/notifyAll可能造成的“惊群效应”(thundering herd),即唤醒了所有等待线程,但其中大部分线程发现条件仍不满足又重新进入等待状态,这会造成不必要的上下文切换和资源消耗。在复杂场景下,
Condition的精准唤醒能力可以显著提升性能。
总结与选择建议:
synchronized关键字。它代码简洁、易于理解,并且现代JVM对其优化得非常好,性能通常足够满足需求。
tryLock())
tryLock(timeout, unit))
lockInterruptibly())
Condition) 实现复杂的等待/通知机制
ReentrantReadWriteLock) 此时,
Lock接口及其实现(如
ReentrantLock)是更好的选择。虽然可能带来轻微的直接性能开销,但其提供的灵活性和控制力,能够帮助你编写出更高效、更健壮的并发代码,从而在整体系统层面实现更好的性能。
最终,对于性能敏感的应用,最好的方法始终是进行实际的基准测试。在你的具体应用场景下,通过测试数据来决定哪种同步机制最适合。但总的来说,不要盲目认为
Lock就一定比
synchronized快,两者的选择更多是基于功能需求和代码可读性。