优化CacheSource
This commit is contained in:
@@ -1653,16 +1653,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
|
|||||||
return CompletableFuture.runAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
return CompletableFuture.runAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> void setnxBytes(final String key, final Convert convert, final Type type, final T value) {
|
|
||||||
setnx(CacheEntryType.BYTES, key, convert.convertToBytes(type, value));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> CompletableFuture<Void> setnxBytesAsync(final String key, final Convert convert, final Type type, final T value) {
|
|
||||||
return CompletableFuture.runAsync(() -> setnxBytes(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void setexBytes(final String key, final int expireSeconds, final byte[] value) {
|
public void setexBytes(final String key, final int expireSeconds, final byte[] value) {
|
||||||
set(CacheEntryType.BYTES, expireSeconds, key, value);
|
set(CacheEntryType.BYTES, expireSeconds, key, value);
|
||||||
@@ -1673,26 +1663,6 @@ public final class CacheMemorySource extends AbstractCacheSource {
|
|||||||
return CompletableFuture.runAsync(() -> setexBytes(key, expireSeconds, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
return CompletableFuture.runAsync(() -> setexBytes(key, expireSeconds, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> void setBytes(final String key, final Convert convert, final Type type, final T value) {
|
|
||||||
set(CacheEntryType.BYTES, key, convert.convertToBytes(type, value));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> CompletableFuture<Void> setBytesAsync(final String key, final Convert convert, final Type type, final T value) {
|
|
||||||
return CompletableFuture.runAsync(() -> setBytes(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> void setexBytes(final String key, final int expireSeconds, final Convert convert, final Type type, final T value) {
|
|
||||||
set(CacheEntryType.BYTES, expireSeconds, key, convert.convertToBytes(type, value));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public <T> CompletableFuture<Void> setexBytesAsync(final String key, final int expireSeconds, final Convert convert, final Type type, final T value) {
|
|
||||||
return CompletableFuture.runAsync(() -> setexBytes(key, expireSeconds, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int getKeySize() {
|
public int getKeySize() {
|
||||||
return container.size();
|
return container.size();
|
||||||
|
|||||||
@@ -90,8 +90,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public void setBytes(final String key, final byte[] value);
|
public void setBytes(final String key, final byte[] value);
|
||||||
|
|
||||||
public <T> void setBytes(final String key, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ setnx ------------------------
|
//------------------------ setnx ------------------------
|
||||||
public <T> void setnx(final String key, final Convert convert, final T value);
|
public <T> void setnx(final String key, final Convert convert, final T value);
|
||||||
|
|
||||||
@@ -105,8 +103,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public void setnxBytes(final String key, final byte[] value);
|
public void setnxBytes(final String key, final byte[] value);
|
||||||
|
|
||||||
public <T> void setnxBytes(final String key, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ setex ------------------------
|
//------------------------ 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 Convert convert, final T value);
|
||||||
|
|
||||||
@@ -120,8 +116,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public void setexBytes(final String key, final int expireSeconds, final byte[] value);
|
public void setexBytes(final String key, final int expireSeconds, final byte[] value);
|
||||||
|
|
||||||
public <T> void setexBytes(final String key, final int expireSeconds, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ xxxx ------------------------
|
//------------------------ xxxx ------------------------
|
||||||
public boolean exists(final String key);
|
public boolean exists(final String key);
|
||||||
|
|
||||||
@@ -375,8 +369,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public CompletableFuture<Void> setBytesAsync(final String key, final byte[] value);
|
public CompletableFuture<Void> setBytesAsync(final String key, final byte[] value);
|
||||||
|
|
||||||
public <T> CompletableFuture<Void> setBytesAsync(final String key, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ setnxAsync ------------------------
|
//------------------------ setnxAsync ------------------------
|
||||||
public <T> CompletableFuture<Void> setnxAsync(final String key, final Convert convert, final T value);
|
public <T> CompletableFuture<Void> setnxAsync(final String key, final Convert convert, final T value);
|
||||||
|
|
||||||
@@ -390,8 +382,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public CompletableFuture<Void> setnxBytesAsync(final String key, final byte[] value);
|
public CompletableFuture<Void> setnxBytesAsync(final String key, final byte[] value);
|
||||||
|
|
||||||
public <T> CompletableFuture<Void> setnxBytesAsync(final String key, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ setexAsync ------------------------
|
//------------------------ 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 Convert convert, final T value);
|
||||||
|
|
||||||
@@ -405,8 +395,6 @@ public interface CacheSource extends Resourcable {
|
|||||||
|
|
||||||
public CompletableFuture<Void> setexBytesAsync(final String key, final int expireSeconds, final byte[] value);
|
public CompletableFuture<Void> setexBytesAsync(final String key, final int expireSeconds, final byte[] value);
|
||||||
|
|
||||||
public <T> CompletableFuture<Void> setexBytesAsync(final String key, final int expireSeconds, final Convert convert, final Type type, final T value);
|
|
||||||
|
|
||||||
//------------------------ xxxxAsync ------------------------
|
//------------------------ xxxxAsync ------------------------
|
||||||
public CompletableFuture<Boolean> existsAsync(final String key);
|
public CompletableFuture<Boolean> existsAsync(final String key);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user