CacheSource优化

This commit is contained in:
redkale
2023-07-18 09:16:41 +08:00
parent 8b3c472d70
commit 0b1c02ac96

View File

@@ -148,6 +148,10 @@ public interface CacheSource extends Resourcable {
return val == null ? defValue : val;
}
default Long getLong(String key) {
return get(key, Long.class);
}
//------------------------ mget ------------------------
default <T> List<T> mget(Type componentType, String... keys) {
return (List) mgetAsync(componentType, keys).join();
@@ -187,6 +191,10 @@ public interface CacheSource extends Resourcable {
return val == null ? defValue : val;
}
default Long getexLong(String key, int expireSeconds) {
return getex(key, expireSeconds, Long.class);
}
//------------------------ getset ------------------------
default <T> T getSet(String key, Convert convert, Type type, T value) {
return getSetAsync(key, convert, type, value).join();
@@ -205,6 +213,10 @@ public interface CacheSource extends Resourcable {
return val == null ? defValue : val;
}
default Long getSetLong(String key, long value) {
return getSet(key, Long.class, value);
}
//------------------------ getdel ------------------------
default <T> T getDel(String key, Type type) {
return (T) getDelAsync(key, type).join();
@@ -219,6 +231,10 @@ public interface CacheSource extends Resourcable {
return val == null ? defValue : val;
}
default Long getDelLong(String key) {
return getDel(key, Long.class);
}
//------------------------ 键 Keys ------------------------
default long del(String... keys) {
return delAsync(keys).join();
@@ -355,6 +371,10 @@ public interface CacheSource extends Resourcable {
return val == null ? defValue : val;
}
default Long hgetLong(String key, String field) {
return hget(key, field, Long.class);
}
default <T> void hset(String key, String field, Convert convert, Type type, T value) {
hsetAsync(key, field, convert, type, value).join();
}
@@ -1005,6 +1025,10 @@ public interface CacheSource extends Resourcable {
return getAsync(key, Long.class).thenApply(v -> v == null ? defValue : (Long) v);
}
default CompletableFuture<Long> getLongAsync(String key) {
return getAsync(key, Long.class);
}
//------------------------ mget ------------------------
public <T> CompletableFuture<List<T>> mgetAsync(Type componentType, String... keys);
@@ -1048,6 +1072,10 @@ public interface CacheSource extends Resourcable {
return getexAsync(key, expireSeconds, Long.class).thenApply(v -> v == null ? defValue : (Long) v);
}
default CompletableFuture<Long> getexLongAsync(String key, int expireSeconds) {
return getexAsync(key, expireSeconds, Long.class);
}
//------------------------ getset ------------------------
public <T> CompletableFuture<T> getSetAsync(String key, Convert convert, Type type, T value);
@@ -1063,6 +1091,10 @@ public interface CacheSource extends Resourcable {
return getSetAsync(key, Long.class, value).thenApply(v -> v == null ? defValue : (Long) v);
}
default CompletableFuture<Long> getSetLongAsync(String key, long value) {
return getSetAsync(key, Long.class, value);
}
//------------------------ getdel ------------------------
public <T> CompletableFuture<T> getDelAsync(String key, Type type);
@@ -1074,6 +1106,10 @@ public interface CacheSource extends Resourcable {
return getDelAsync(key, Long.class).thenApply(v -> v == null ? defValue : (Long) v);
}
default CompletableFuture<Long> getDelLongAsync(String key) {
return getDelAsync(key, Long.class);
}
//------------------------ 键 Keys ------------------------
public CompletableFuture<Long> delAsync(String... keys);
@@ -1121,6 +1157,10 @@ public interface CacheSource extends Resourcable {
return hgetAsync(key, field, Long.class).thenApply(v -> v == null ? defValue : (Long) v);
}
default CompletableFuture<Long> hgetLongAsync(String key, String field) {
return hgetAsync(key, field, Long.class);
}
public <T> CompletableFuture<Void> hsetAsync(String key, String field, Convert convert, Type type, T value);
default <T> CompletableFuture<Void> hsetAsync(String key, String field, Type type, T value) {