lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CacheSource增加getIfAbsent系列方法

Browse Source
This commit is contained in:
Redkale
2018-01-25 14:24:28 +08:00
parent 355441e795
commit 66baca51d7
1 changed files with 45 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/org/redkale/source/CacheSource.java
View File

@@ -8,6 +8,7 @@ package org.redkale.source;
import java.lang.reflect.Type;
import java.util.*;
import java.util.concurrent.*;
import java.util.function.Function;
import org.redkale.convert.ConvertColumn;
import org.redkale.convert.json.JsonFactory;
import org.redkale.util.ConstructorParameters;
@@ -36,8 +37,26 @@ public interface CacheSource<V extends Object> {
public V get(final String key);
default V getIfAbsent(final String key, Function<String, ? extends V> mappingFunction) {
V rs = get(key);
if (rs == null) {
rs = mappingFunction.apply(key);
if (rs != null) set(key, rs);
}
return rs;
}
public V getAndRefresh(final String key, final int expireSeconds);
default V getAndRefreshIfAbsent(final String key, final int expireSeconds, Function<String, ? extends V> mappingFunction) {
V rs = getAndRefresh(key, expireSeconds);
if (rs == null) {
rs = mappingFunction.apply(key);
if (rs != null) set(expireSeconds, key, rs);
}
return rs;
}
public void refresh(final String key, final int expireSeconds);
public void set(final String key, final V value);
@@ -127,8 +146,34 @@ public interface CacheSource<V extends Object> {
public CompletableFuture<V> getAsync(final String key);
default CompletableFuture<V> getIfAbsentAsync(final String key, Function<String, ? extends V> mappingFunction) {
return getAsync(key).thenCompose((V rs) -> {
if (rs == null) {
rs = mappingFunction.apply(key);
if (rs != null) {
final V v = rs;
return setAsync(key, rs).thenApply((k) -> v);
}
}
return CompletableFuture.completedFuture(rs);
});
}
public CompletableFuture<V> getAndRefreshAsync(final String key, final int expireSeconds);
default CompletableFuture<V> getAndRefreshIfAbsentAsync(final String key, final int expireSeconds, Function<String, ? extends V> mappingFunction) {
return getAndRefreshAsync(key, expireSeconds).thenCompose((V rs) -> {
if (rs == null) {
rs = mappingFunction.apply(key);
if (rs != null) {
final V v = rs;
return setAsync(expireSeconds, key, rs).thenApply((k) -> v);
}
}
return CompletableFuture.completedFuture(rs);
});
}
public CompletableFuture<Void> refreshAsync(final String key, final int expireSeconds);
public CompletableFuture<Void> setAsync(final String key, final V value);