如何使用 StampedLock 乐观锁定?(我无法理解 java 文档中的代码示例)
How to to use StampedLock optimistic locking ?(I can't understand code sample from java doc)
最近我了解到存在 StampedLock
?
https://docs.oracle.com/javase/10/docs/api/java/util/concurrent/locks/StampedLock.html
我意识到它改进了 ReentrantReadWriteLock,但有一些不同:
- 不可重入
- 支持光学锁
- 支持从readLock升级到writeLock
我也阅读了示例 frpm javadoc,但我不理解该代码:
class Point {
private double x, y;
private final StampedLock sl = new StampedLock();
// a read-only method
// upgrade from optimistic read to read lock
double distanceFromOrigin() {
long stamp = sl.tryOptimisticRead();
try {
retryHoldingLock: for (;; stamp = sl.readLock()) {
if (stamp == 0L)
continue retryHoldingLock;
// possibly racy reads
double currentX = x;
double currentY = y;
if (!sl.validate(stamp))
continue retryHoldingLock;
return Math.hypot(currentX, currentY);
}
} finally {
if (StampedLock.isReadLockStamp(stamp))
sl.unlockRead(stamp);
}
}
}
possibly racy reads
是什么意思? [在评论中回答]
如果另一个线程读取 x
或 y
是否有问题? [在评论中回答]
为什么tryOptimisticRead失败时先执行tryOptimisticRead,然后在for循环中执行readLock?这是什么逻辑?
为什么我们有 if (StampedLock.isReadLockStamp(stamp))
inside finally block vbefore unlock ?
why do we execute tryOptimisticRead first and readLock in the for loop in case of tryOptimisticRead failure? what the logic?
最好的情况是我们能够读取 x
和 y
而无需获取锁。这并不意味着我们不建立 happens-before 关系,它只是意味着我们不需要调用可能的阻塞操作。
tryOptimisticRead
returns 我们邮票值。此 volatile
内部状态读取确定 在对该标记值进行易失性写入之前写入的任何内容在随后的读取 之后都是可见的。这意味着,如果在 tryOptimisticRead
中返回的标记值在您读取 x
和 y
时没有改变,则不会发生另一次写入,我们拥有最新的值。但是,如果标记值确实发生变化,则所有赌注均无效,您需要保护自己,如下所述。
根据您的用例,x
和 y
有可能会在您执行 distanceFromOrigin
的整个过程中的某个时间点发生变化。如果 x
和 y
发生变化,并且可能经常发生变化,那么您将希望最终获得成功。
readLock
是程序的表达方式 "Ok, I give up, let's just read it in a blocking fashion"。理论上,您可以在最终调用 readLock
之前将您的代码写入 tryOptimisticRead
几次,但您将想要给自己一个机会,以防 x
和 y
] 不断更新。
Why do we have if (StampedLock.isReadLockStamp(stamp)) inside finally block vbefore unlock ?
如果调用了readLock
,您必须在退出前释放它,以便后续的writeLock
可以获得锁。如果您在 tryOptimisticRead
中取得成功,您将不必释放 readLock
,因为您一开始就不需要获取它。
最近我了解到存在 StampedLock
?
https://docs.oracle.com/javase/10/docs/api/java/util/concurrent/locks/StampedLock.html 我意识到它改进了 ReentrantReadWriteLock,但有一些不同:
- 不可重入
- 支持光学锁
- 支持从readLock升级到writeLock
我也阅读了示例 frpm javadoc,但我不理解该代码:
class Point {
private double x, y;
private final StampedLock sl = new StampedLock();
// a read-only method
// upgrade from optimistic read to read lock
double distanceFromOrigin() {
long stamp = sl.tryOptimisticRead();
try {
retryHoldingLock: for (;; stamp = sl.readLock()) {
if (stamp == 0L)
continue retryHoldingLock;
// possibly racy reads
double currentX = x;
double currentY = y;
if (!sl.validate(stamp))
continue retryHoldingLock;
return Math.hypot(currentX, currentY);
}
} finally {
if (StampedLock.isReadLockStamp(stamp))
sl.unlockRead(stamp);
}
}
}
possibly racy reads
是什么意思? [在评论中回答]
如果另一个线程读取 x
或 y
是否有问题? [在评论中回答]
为什么tryOptimisticRead失败时先执行tryOptimisticRead,然后在for循环中执行readLock?这是什么逻辑?
为什么我们有 if (StampedLock.isReadLockStamp(stamp))
inside finally block vbefore unlock ?
why do we execute tryOptimisticRead first and readLock in the for loop in case of tryOptimisticRead failure? what the logic?
最好的情况是我们能够读取 x
和 y
而无需获取锁。这并不意味着我们不建立 happens-before 关系,它只是意味着我们不需要调用可能的阻塞操作。
tryOptimisticRead
returns 我们邮票值。此 volatile
内部状态读取确定 在对该标记值进行易失性写入之前写入的任何内容在随后的读取 之后都是可见的。这意味着,如果在 tryOptimisticRead
中返回的标记值在您读取 x
和 y
时没有改变,则不会发生另一次写入,我们拥有最新的值。但是,如果标记值确实发生变化,则所有赌注均无效,您需要保护自己,如下所述。
根据您的用例,x
和 y
有可能会在您执行 distanceFromOrigin
的整个过程中的某个时间点发生变化。如果 x
和 y
发生变化,并且可能经常发生变化,那么您将希望最终获得成功。
readLock
是程序的表达方式 "Ok, I give up, let's just read it in a blocking fashion"。理论上,您可以在最终调用 readLock
之前将您的代码写入 tryOptimisticRead
几次,但您将想要给自己一个机会,以防 x
和 y
] 不断更新。
Why do we have if (StampedLock.isReadLockStamp(stamp)) inside finally block vbefore unlock ?
如果调用了readLock
,您必须在退出前释放它,以便后续的writeLock
可以获得锁。如果您在 tryOptimisticRead
中取得成功,您将不必释放 readLock
,因为您一开始就不需要获取它。