Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

updated PPTX

Browse Source
This commit is contained in:
cotton-ben
2020-07-03 05:28:11 -04:00
parent b9c1ae60dc
commit 4225aa2e2b
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/net/openhft/chronicle/map/fromdocs/acid/ChronicleStampedLock.pptx
BIN
View File
Binary file not shown.
src/test/java/net/openhft/chronicle/map/fromdocs/acid/revelations/DirtyReadOffender.java
+6 -9
View File
@@ -1,10 +1,7 @@
package net.openhft.chronicle.map.fromdocs.acid.revelations;
import net.openhft.chronicle.map.ChronicleMap;
import net.openhft.chronicle.map.fromdocs.BondVOInterface;
import net.openhft.chronicle.map.fromdocs.acid.revelations.DirtyReadTolerance;
import java.util.Scanner;
import java.util.concurrent.locks.StampedLock;
@@ -17,7 +14,7 @@ public class DirtyReadOffender {
try {
String isoLevel = args[0];
long sleepMock = Long.parseLong(args[1]);
long sleepT = Long.parseLong(args[1]);
ChronicleMap<String, BondVOInterface> chm =
DirtyReadTolerance.offHeap(
@@ -33,9 +30,9 @@ public class DirtyReadOffender {
chm.acquireUsing("Offender ", cslMock); // mock ChronicleStampLock
System.out.println(
" @t=" + System.currentTimeMillis() +
" DirtyReadOffender sleeping "+sleepMock+" seconds "
" DirtyReadOffender sleeping "+sleepT+" seconds "
);
Thread.sleep(sleepMock * 1_000);
Thread.sleep(sleepT * 1_000);
System.out.println(
" @t=" + System.currentTimeMillis() +
" DirtyReadOffender awakening "
@@ -47,13 +44,12 @@ public class DirtyReadOffender {
* START
*
*/
long stamp = 0;
System.out.println(
" @t=" + System.currentTimeMillis() +
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
);
ChronicleStampedLock offHeapLock = new ChronicleStampedLock();
StampedLock offHeapLock = new ChronicleStampedLock();
while ((stamp = offHeapLock.tryWriteLock()) == 0) {
;
}
@@ -82,7 +78,8 @@ public class DirtyReadOffender {
offHeapLock.unlockWrite(stamp);
System.out.println(
" @t=" + System.currentTimeMillis() +
" DirtyReadOffender called offHeapLock.unlockWrite(stamp);"
" DirtyReadOffender called " +
"offHeapLock.unlockWrite(stamp);"
);
}
/**
src/test/java/net/openhft/chronicle/map/fromdocs/acid/revelations/DirtyReadVictim.java
+4 -1
View File
@@ -3,6 +3,9 @@ package net.openhft.chronicle.map.fromdocs.acid.revelations;
import net.openhft.chronicle.map.ChronicleMap;
import net.openhft.chronicle.map.fromdocs.BondVOInterface;
import net.openhft.chronicle.map.fromdocs.acid.ChronicleAcidIsolation;
import java.util.concurrent.locks.StampedLock;
import static net.openhft.chronicle.values.Values.newNativeReference;
public class DirtyReadVictim {
@@ -27,7 +30,7 @@ public class DirtyReadVictim {
" ,,@t=" + System.currentTimeMillis() +
" DirtyReadVictim ENTERING offHeapLock.tryOptimisticRead()"
);
ChronicleStampedLock offHeapLock = new ChronicleStampedLock();
StampedLock offHeapLock = new ChronicleStampedLock();
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {
;
}