autumn/JChargePointProtocol
1
0
Fork 0
mirror of https://gitee.com/san-bing/JChargePointProtocol synced 2026-05-05 10:29:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

version 类型修正

Browse Source
This commit is contained in:
三丙
2024-12-17 14:07:33 +08:00
parent 7d2dd2a29f
commit d7eb3d2ea9
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
jcpp-infrastructure-cache/src/main/java/sanbing/jcpp/infrastructure/cache/VersionedCaffeineCache.java vendored
View File

@@ -18,7 +18,7 @@ public abstract class VersionedCaffeineCache<K extends VersionedCacheKey, V exte
@Override @Override
public CacheValueWrapper<V> get(K key) { public CacheValueWrapper<V> get(K key) {
JCPPPair<Long, V> versionValuePair = doGet(key); JCPPPair<Integer, V> versionValuePair = doGet(key);
if (versionValuePair != null) { if (versionValuePair != null) {
return SimpleCacheValueWrapper.wrap(versionValuePair.getSecond()); return SimpleCacheValueWrapper.wrap(versionValuePair.getSecond());
} }
@@ -37,7 +37,7 @@ public abstract class VersionedCaffeineCache<K extends VersionedCacheKey, V exte
private void doPut(K key, V value, Integer version) { private void doPut(K key, V value, Integer version) {
lock.lock(); lock.lock();
try { try {
JCPPPair<Long, V> versionValuePair = doGet(key); JCPPPair<Integer, V> versionValuePair = doGet(key);
if (versionValuePair == null || version > versionValuePair.getFirst()) { if (versionValuePair == null || version > versionValuePair.getFirst()) {
failAllTransactionsByKey(key); failAllTransactionsByKey(key);
cache.put(key, wrapValue(value, version)); cache.put(key, wrapValue(value, version));
@@ -48,10 +48,10 @@ public abstract class VersionedCaffeineCache<K extends VersionedCacheKey, V exte
} }
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private JCPPPair<Long, V> doGet(K key) { private JCPPPair<Integer, V> doGet(K key) {
Cache.ValueWrapper source = cache.get(key); Cache.ValueWrapper source = cache.get(key);
if (source != null && source.get() instanceof JCPPPair<?, ?> pair) { if (source != null && source.get() instanceof JCPPPair<?, ?> pair) {
return (JCPPPair<Long, V>) pair; return (JCPPPair<Integer, V>) pair;
} }
return null; return null;
} }