乐观读锁通过非阻塞方式提升并发性能,适用于读多写少场景。StampedLock的tryOptimisticRead获取戳记,validate验证数据一致性,若失败则降级为悲观读锁,确保正确性的同时减少线程阻塞,提高吞吐量。
在高并发场景中,读操作通常远多于写操作。为了提升读性能,Java 8 引入了 StampedLock,它比传统的 ReentrantReadWriteLock 更高效,尤其是在读多写少的情况下。其中,乐观读锁(Optimistic Reading) 是 StampedLock 的一大亮点,能显著减少线程阻塞和上下文切换,提高系统吞吐量。
与传统读锁不同,乐观读锁不会阻塞写线程,也不需要立即获取锁。它假设读取期间数据不会被修改,先进行读操作,之后再验证读取过程中是否有写入发生。如果验证通过,数据一致;否则,降级为悲观读锁重新读取。
这种方式适用于读操作极快、冲突概率低的场景,避免了加锁开销,提升了并发性能。
StampedLock 提供了三种模式:写锁、悲观读锁、乐观读锁。与乐观读相关的主要方法有:
以下是一个使用乐观读锁的示例,展示如何安全地读取共享数据:
import java.util.concurrent.locks.StampedLock;public class OptimisticReadingExample { private double x, y; private final StampedLock stampedLock = new StampedLock();
// 计算距离原点的距离(使用乐观读) public double distanceFromOrigin() { // 尝试乐观读 long stamp = stampedLock.tryOptimisticRead(); double currentX = x; double currentY = y; // 验证读期间是否有写操作 if (!stampedLock.validate(stamp)) { // 乐观读失败,升级为悲观读锁 stamp = stampedLock.readLock(); try { currentX = x; currentY = y; } finally { stampedLock.unlockRead(stamp); } } return Math.sqrt(currentX * currentX + currentY * currentY); } // 写操作需要获取写锁 public void move(double deltaX, double deltaY) { long stamp = stampedLock.writeLock(); try { x += deltaX; y += deltaY; } finally { stampedLock.unlockWrite(stamp); } }}
在这个例子中:
tryOptimisticRead() 获取戳记。x 和 y。validate(stamp) 检查数据一致性。基本上就这些。StampedLock 的乐观读机制为高并发读场景提供了更高效的解决方案,合理使用可以显著提升系统性能。关键在于判断业务场景是否适合——读多、写少、读操作快,是它的最佳舞台。