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

优化CacheSource部分方法名

Browse Source
This commit is contained in:
Redkale
2022-12-21 17:35:43 +08:00
parent c48ba58d55
commit 616a501af7
3 changed files with 73 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/redkale/boot/Application.java
View File

@@ -1052,7 +1052,7 @@ public final class Application {
return server;
}
// if (type == WatchFactory.class) {
// field.set(src, application.watchFactory);
// field.setex(src, application.watchFactory);
// }
return null;
} catch (Exception e) {

38
src/main/java/org/redkale/source/CacheMemorySource.java
View File

@@ -790,53 +790,53 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public <T> void set(final int expireSeconds, String key, Convert convert, T value) {
public <T> void setex(final int expireSeconds, String key, Convert convert, T value) {
set(CacheEntryType.OBJECT, expireSeconds, key, value);
}
@Override
public <T> void set(final int expireSeconds, String key, Type type, T value) {
public <T> void setex(final int expireSeconds, String key, Type type, T value) {
set(CacheEntryType.OBJECT, expireSeconds, key, value);
}
@Override
public <T> void set(final int expireSeconds, String key, Convert convert, Type type, T value) {
public <T> void setex(final int expireSeconds, String key, Convert convert, Type type, T value) {
set(CacheEntryType.OBJECT, expireSeconds, key, value);
}
@Override
public void setString(int expireSeconds, String key, String value) {
public void setexString(int expireSeconds, String key, String value) {
set(CacheEntryType.STRING, expireSeconds, key, value);
}
@Override
public void setLong(int expireSeconds, String key, long value) {
public void setexLong(int expireSeconds, String key, long value) {
set(CacheEntryType.LONG, expireSeconds, key, value);
}
@Override
public <T> CompletableFuture<Void> setAsync(int expireSeconds, String key, Convert convert, T value) {
return CompletableFuture.runAsync(() -> set(expireSeconds, key, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
public <T> CompletableFuture<Void> setexAsync(int expireSeconds, String key, Convert convert, T value) {
return CompletableFuture.runAsync(() -> setex(expireSeconds, key, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setAsync(int expireSeconds, String key, Type type, T value) {
return CompletableFuture.runAsync(() -> set(expireSeconds, key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
public <T> CompletableFuture<Void> setexAsync(int expireSeconds, String key, Type type, T value) {
return CompletableFuture.runAsync(() -> setex(expireSeconds, key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setAsync(int expireSeconds, String key, Convert convert, Type type, T value) {
return CompletableFuture.runAsync(() -> set(expireSeconds, key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
public <T> CompletableFuture<Void> setexAsync(int expireSeconds, String key, Convert convert, Type type, T value) {
return CompletableFuture.runAsync(() -> setex(expireSeconds, key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public CompletableFuture<Void> setStringAsync(int expireSeconds, String key, String value) {
return CompletableFuture.runAsync(() -> setString(expireSeconds, key, value), getExecutor()).whenComplete(futureCompleteConsumer);
public CompletableFuture<Void> setexStringAsync(int expireSeconds, String key, String value) {
return CompletableFuture.runAsync(() -> setexString(expireSeconds, key, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public CompletableFuture<Void> setLongAsync(int expireSeconds, String key, long value) {
return CompletableFuture.runAsync(() -> setLong(expireSeconds, key, value), getExecutor()).whenComplete(futureCompleteConsumer);
public CompletableFuture<Void> setexLongAsync(int expireSeconds, String key, long value) {
return CompletableFuture.runAsync(() -> setexLong(expireSeconds, key, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
@@ -1419,7 +1419,7 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public CompletableFuture<Void> setBytesAsync(final int expireSeconds, final String key, byte[] value) {
public CompletableFuture<Void> setexBytesAsync(final int expireSeconds, final String key, byte[] value) {
return CompletableFuture.runAsync(() -> setBytes(expireSeconds, key, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@@ -1434,13 +1434,13 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public <T> void setBytes(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
public <T> void setexBytes(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
set(CacheEntryType.BYTES, expireSeconds, key, convert.convertToBytes(type, value));
}
@Override
public <T> CompletableFuture<Void> setBytesAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
return CompletableFuture.runAsync(() -> setBytes(expireSeconds, key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
public <T> CompletableFuture<Void> setexBytesAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
return CompletableFuture.runAsync(() -> setexBytes(expireSeconds, key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override

66
src/main/java/org/redkale/source/CacheSource.java
View File

@@ -115,11 +115,26 @@ public interface CacheSource extends Resourcable {
public <T> T getSet(final String key, final Convert convert, final Type type, final T value);
public <T> void set(final int expireSeconds, final String key, final Convert convert, final T value);
@Deprecated
default <T> void set(final int expireSeconds, final String key, final Convert convert, final T value) {
setex(expireSeconds, key, convert, value);
}
public <T> void set(final int expireSeconds, final String key, final Type type, final T value);
@Deprecated
default <T> void set(final int expireSeconds, final String key, final Type type, final T value) {
setex(expireSeconds, key, type, value);
}
public <T> void set(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
@Deprecated
default <T> void set(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
setex(expireSeconds, key, convert, type, value);
}
public <T> void setex(final int expireSeconds, final String key, final Convert convert, final T value);
public <T> void setex(final int expireSeconds, final String key, final Type type, final T value);
public <T> void setex(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
@Deprecated
default void setExpireSeconds(final String key, final int expireSeconds) {
@@ -179,7 +194,7 @@ public interface CacheSource extends Resourcable {
public <T> void setBytes(final String key, final Convert convert, final Type type, final T value);
public <T> void setBytes(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public <T> void setexBytes(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public List<String> queryKeys();
@@ -199,7 +214,12 @@ public interface CacheSource extends Resourcable {
public void setnxString(final String key, final String value);
public void setString(final int expireSeconds, final String key, final String value);
@Deprecated
default void setString(final int expireSeconds, final String key, final String value) {
setexString(expireSeconds, key, value);
}
public void setexString(final int expireSeconds, final String key, final String value);
public Map<String, String> getStringMap(final String... keys);
@@ -235,7 +255,12 @@ public interface CacheSource extends Resourcable {
public void setnxLong(final String key, final long value);
public void setLong(final int expireSeconds, final String key, final long value);
@Deprecated
default void setLong(final int expireSeconds, final String key, final long value) {
setexLong(expireSeconds, key, value);
}
public void setexLong(final int expireSeconds, final String key, final long value);
public Map<String, Long> getLongMap(final String... keys);
@@ -286,11 +311,26 @@ public interface CacheSource extends Resourcable {
public <T> CompletableFuture<T> getSetAsync(final String key, final Convert convert, final Type type, final T value);
public <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final T value);
@Deprecated
default <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final T value) {
return setexAsync(expireSeconds, key, convert, value);
}
public <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Type type, final T value);
@Deprecated
default <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Type type, final T value) {
return setexAsync(expireSeconds, key, type, value);
}
public <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
@Deprecated
default <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value) {
return setexAsync(expireSeconds, key, convert, type, value);
}
public <T> CompletableFuture<Void> setexAsync(final int expireSeconds, final String key, final Convert convert, final T value);
public <T> CompletableFuture<Void> setexAsync(final int expireSeconds, final String key, final Type type, final T value);
public <T> CompletableFuture<Void> setexAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
@Deprecated
default CompletableFuture<Void> setExpireSecondsAsync(final String key, final int expireSeconds) {
@@ -403,11 +443,11 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> setBytesAsync(final String key, final byte[] value);
public CompletableFuture<Void> setBytesAsync(final int expireSeconds, final String key, final byte[] value);
public CompletableFuture<Void> setexBytesAsync(final int expireSeconds, final String key, final byte[] value);
public <T> CompletableFuture<Void> setBytesAsync(final String key, final Convert convert, final Type type, final T value);
public <T> CompletableFuture<Void> setBytesAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public <T> CompletableFuture<Void> setexBytesAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public CompletableFuture<List<String>> queryKeysAsync();
@@ -427,7 +467,7 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> setnxStringAsync(final String key, final String value);
public CompletableFuture<Void> setStringAsync(final int expireSeconds, final String key, final String value);
public CompletableFuture<Void> setexStringAsync(final int expireSeconds, final String key, final String value);
public CompletableFuture<Map<String, String>> getStringMapAsync(final String... keys);
@@ -463,7 +503,7 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> setnxLongAsync(final String key, long value);
public CompletableFuture<Void> setLongAsync(final int expireSeconds, final String key, final long value);
public CompletableFuture<Void> setexLongAsync(final int expireSeconds, final String key, final long value);
public CompletableFuture<Map<String, Long>> getLongMapAsync(final String... keys);