From 9200a3a32b94f230fc29f0af9f5185dcc78831ac Mon Sep 17 00:00:00 2001 From: Redkale Date: Mon, 26 Dec 2022 19:57:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96CacheSource?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/redkale/source/CacheMemorySource.java | 30 ------------------- .../java/org/redkale/source/CacheSource.java | 12 -------- 2 files changed, 42 deletions(-) diff --git a/src/main/java/org/redkale/source/CacheMemorySource.java b/src/main/java/org/redkale/source/CacheMemorySource.java index df82cfb6e..2d6a32468 100644 --- a/src/main/java/org/redkale/source/CacheMemorySource.java +++ b/src/main/java/org/redkale/source/CacheMemorySource.java @@ -1653,16 +1653,6 @@ public final class CacheMemorySource extends AbstractCacheSource { return CompletableFuture.runAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer); } - @Override - public void setnxBytes(final String key, final Convert convert, final Type type, final T value) { - setnx(CacheEntryType.BYTES, key, convert.convertToBytes(type, value)); - } - - @Override - public CompletableFuture 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 public void setexBytes(final String key, final int expireSeconds, final byte[] 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); } - @Override - public void setBytes(final String key, final Convert convert, final Type type, final T value) { - set(CacheEntryType.BYTES, key, convert.convertToBytes(type, value)); - } - - @Override - public CompletableFuture 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 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 CompletableFuture 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 public int getKeySize() { return container.size(); diff --git a/src/main/java/org/redkale/source/CacheSource.java b/src/main/java/org/redkale/source/CacheSource.java index 2ea2c94d5..712214409 100644 --- a/src/main/java/org/redkale/source/CacheSource.java +++ b/src/main/java/org/redkale/source/CacheSource.java @@ -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 Convert convert, final Type type, final T value); - //------------------------ setnx ------------------------ public 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 Convert convert, final Type type, final T value); - //------------------------ setex ------------------------ public 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 Convert convert, final Type type, final T value); - //------------------------ xxxx ------------------------ public boolean exists(final String key); @@ -375,8 +369,6 @@ public interface CacheSource extends Resourcable { public CompletableFuture setBytesAsync(final String key, final byte[] value); - public CompletableFuture setBytesAsync(final String key, final Convert convert, final Type type, final T value); - //------------------------ setnxAsync ------------------------ public CompletableFuture setnxAsync(final String key, final Convert convert, final T value); @@ -390,8 +382,6 @@ public interface CacheSource extends Resourcable { public CompletableFuture setnxBytesAsync(final String key, final byte[] value); - public CompletableFuture setnxBytesAsync(final String key, final Convert convert, final Type type, final T value); - //------------------------ setexAsync ------------------------ public CompletableFuture setexAsync(final String key, final int expireSeconds, final Convert convert, final T value); @@ -405,8 +395,6 @@ public interface CacheSource extends Resourcable { public CompletableFuture setexBytesAsync(final String key, final int expireSeconds, final byte[] value); - public CompletableFuture setexBytesAsync(final String key, final int expireSeconds, final Convert convert, final Type type, final T value); - //------------------------ xxxxAsync ------------------------ public CompletableFuture existsAsync(final String key);