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-26 22:48:59 +08:00
parent ebd010b6d9
commit 441a74a7c9
2 changed files with 2 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -252,11 +252,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
return entry.mapValue.contains(field);
}
@Override
public <T> void hset(final String key, final String field, final Convert convert, final T value) {
hset(CacheEntryType.MAP, key, field, value);
}
@Override
public <T> void hset(final String key, final String field, final Type type, final T value) {
hset(CacheEntryType.MAP, key, field, value);
@@ -277,11 +272,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
hset(CacheEntryType.MAP, key, field, value);
}
@Override
public <T> void hsetnx(final String key, final String field, final Convert convert, final T value) {
hsetnx(CacheEntryType.MAP, key, field, value);
}
@Override
public <T> void hsetnx(final String key, final String field, final Type type, final T value) {
hsetnx(CacheEntryType.MAP, key, field, value);
@@ -468,11 +458,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
return CompletableFuture.supplyAsync(() -> hexists(key, field), getExecutor());
}
@Override
public <T> CompletableFuture<Void> hsetAsync(final String key, final String field, final Convert convert, final T value) {
return CompletableFuture.runAsync(() -> hset(key, field, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> hsetAsync(final String key, final String field, final Type type, final T value) {
return CompletableFuture.runAsync(() -> hset(key, field, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
@@ -493,11 +478,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
return CompletableFuture.runAsync(() -> hsetLong(key, field, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Convert convert, final T value) {
return CompletableFuture.runAsync(() -> hsetnx(key, field, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Type type, final T value) {
return CompletableFuture.runAsync(() -> hsetnx(key, field, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
@@ -711,11 +691,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
});
}
@Override
public <T> void set(String key, Convert convert, T value) {
set(CacheEntryType.OBJECT, key, value);
}
@Override
public <T> void set(String key, Type type, T value) {
set(CacheEntryType.OBJECT, key, value);
@@ -726,11 +701,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
set(CacheEntryType.OBJECT, key, value);
}
@Override
public <T> void setnx(String key, Convert convert, T value) {
setnx(CacheEntryType.OBJECT, key, value);
}
@Override
public <T> void setnx(String key, Type type, T value) {
setnx(CacheEntryType.OBJECT, key, value);
@@ -785,11 +755,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
return CompletableFuture.runAsync(() -> mset(map), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setAsync(String key, Convert convert, T value) {
return CompletableFuture.runAsync(() -> set(key, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setAsync(String key, Type type, T value) {
return CompletableFuture.runAsync(() -> set(key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
@@ -800,11 +765,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
return CompletableFuture.runAsync(() -> set(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setnxAsync(String key, Convert convert, T value) {
return CompletableFuture.runAsync(() -> setnx(key, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setnxAsync(String key, Type type, T value) {
return CompletableFuture.runAsync(() -> setnx(key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
@@ -863,11 +823,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
}
@Override
public <T> void setex(String key, int expireSeconds, Convert convert, T value) {
set(CacheEntryType.OBJECT, expireSeconds, key, value);
}
@Override
public <T> void setex(String key, int expireSeconds, Type type, T value) {
set(CacheEntryType.OBJECT, expireSeconds, key, value);
@@ -888,11 +843,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
set(CacheEntryType.LONG, expireSeconds, key, value);
}
@Override
public <T> CompletableFuture<Void> setexAsync(String key, int expireSeconds, Convert convert, T value) {
return CompletableFuture.runAsync(() -> setex(key, expireSeconds, convert, value), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public <T> CompletableFuture<Void> setexAsync(String key, int expireSeconds, Type type, T value) {
return CompletableFuture.runAsync(() -> setex(key, expireSeconds, type, value), getExecutor()).whenComplete(futureCompleteConsumer);

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

@@ -114,8 +114,6 @@ public interface CacheSource extends Resourcable {
public void mset(final Map map);
public <T> void set(final String key, final Convert convert, final T value);
public <T> void set(final String key, final Type type, final T value);
public <T> void set(final String key, final Convert convert, final Type type, final T value);
@@ -127,8 +125,6 @@ public interface CacheSource extends Resourcable {
public void setBytes(final String key, final byte[] value);
//------------------------ setnx ------------------------
public <T> void setnx(final String key, final Convert convert, final T value);
public <T> void setnx(final String key, final Type type, final T value);
public <T> void setnx(final String key, final Convert convert, final Type type, final T value);
@@ -140,8 +136,6 @@ public interface CacheSource extends Resourcable {
public void setnxBytes(final String key, final byte[] value);
//------------------------ setex ------------------------
public <T> void setex(final String key, final int expireSeconds, final Convert convert, final T value);
public <T> void setex(final String key, final int expireSeconds, final Type type, final T value);
public <T> void setex(final String key, final int expireSeconds, final Convert convert, final Type type, final T value);
@@ -177,8 +171,6 @@ public interface CacheSource extends Resourcable {
public long hgetLong(final String key, final String field, long defValue);
//------------------------ hset ------------------------
public <T> void hset(final String key, final String field, final Convert convert, final T value);
public <T> void hset(final String key, final String field, final Type type, final T value);
public <T> void hset(final String key, final String field, final Convert convert, final Type type, final T value);
@@ -188,8 +180,6 @@ public interface CacheSource extends Resourcable {
public void hsetLong(final String key, final String field, final long value);
//------------------------ hsetnx ------------------------
public <T> void hsetnx(final String key, final String field, final Convert convert, final T value);
public <T> void hsetnx(final String key, final String field, final Type type, final T value);
public <T> void hsetnx(final String key, final String field, final Convert convert, final Type type, final T value);
@@ -429,8 +419,6 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> msetAsync(final Map map);
public <T> CompletableFuture<Void> setAsync(final String key, final Convert convert, final T value);
public <T> CompletableFuture<Void> setAsync(final String key, final Type type, final T value);
public <T> CompletableFuture<Void> setAsync(final String key, final Convert convert, final Type type, final T value);
@@ -442,8 +430,6 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> setBytesAsync(final String key, final byte[] value);
//------------------------ setnxAsync ------------------------
public <T> CompletableFuture<Void> setnxAsync(final String key, final Convert convert, final T value);
public <T> CompletableFuture<Void> setnxAsync(final String key, final Type type, final T value);
public <T> CompletableFuture<Void> setnxAsync(final String key, final Convert convert, final Type type, final T value);
@@ -455,8 +441,6 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> setnxBytesAsync(final String key, final byte[] value);
//------------------------ setexAsync ------------------------
public <T> CompletableFuture<Void> setexAsync(final String key, final int expireSeconds, final Convert convert, final T value);
public <T> CompletableFuture<Void> setexAsync(final String key, final int expireSeconds, final Type type, final T value);
public <T> CompletableFuture<Void> setexAsync(final String key, final int expireSeconds, final Convert convert, final Type type, final T value);
@@ -492,8 +476,6 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Long> hgetLongAsync(final String key, final String field, long defValue);
//------------------------ hsetAsync ------------------------
public <T> CompletableFuture<Void> hsetAsync(final String key, final String field, final Convert convert, final T value);
public <T> CompletableFuture<Void> hsetAsync(final String key, final String field, final Type type, final T value);
public <T> CompletableFuture<Void> hsetAsync(final String key, final String field, final Convert convert, final Type type, final T value);
@@ -503,8 +485,6 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Void> hsetLongAsync(final String key, final String field, final long value);
//------------------------ hsetnxAsync ------------------------
public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Convert convert, final T value);
public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Type type, final T value);
public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Convert convert, final Type type, final T value);
@@ -664,7 +644,7 @@ public interface CacheSource extends Resourcable {
@Deprecated
default <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final T value) {
return setexAsync(key, expireSeconds, convert, value);
return setexAsync(key, expireSeconds, convert, value.getClass(), value);
}
@Deprecated
@@ -699,7 +679,7 @@ public interface CacheSource extends Resourcable {
@Deprecated
default <T> void set(final int expireSeconds, final String key, final Convert convert, final T value) {
setex(key, expireSeconds, convert, value);
setex(key, expireSeconds, convert, value.getClass(), value);
}
@Deprecated