diff --git a/src/main/java/org/redkale/source/CacheMemorySource.java b/src/main/java/org/redkale/source/CacheMemorySource.java index 60a821221..b0603c0db 100644 --- a/src/main/java/org/redkale/source/CacheMemorySource.java +++ b/src/main/java/org/redkale/source/CacheMemorySource.java @@ -1614,7 +1614,7 @@ public final class CacheMemorySource extends AbstractCacheSource { } @Override - public int dbsize() { + public long dbsize() { return container.size(); } @@ -1649,8 +1649,8 @@ public final class CacheMemorySource extends AbstractCacheSource { } @Override - public CompletableFuture dbsizeAsync() { - return CompletableFuture.completedFuture(container.size()); + public CompletableFuture dbsizeAsync() { + return CompletableFuture.completedFuture((long) container.size()); } @Override diff --git a/src/main/java/org/redkale/source/CacheSource.java b/src/main/java/org/redkale/source/CacheSource.java index 806bfed2c..d5517bcdc 100644 --- a/src/main/java/org/redkale/source/CacheSource.java +++ b/src/main/java/org/redkale/source/CacheSource.java @@ -297,7 +297,7 @@ public interface CacheSource extends Resourcable { public List keys(String pattern); - public int dbsize(); + public long dbsize(); //------------------------ collection ------------------------ @Deprecated @@ -598,7 +598,7 @@ public interface CacheSource extends Resourcable { public CompletableFuture> keysAsync(String pattern); - public CompletableFuture dbsizeAsync(); + public CompletableFuture dbsizeAsync(); //------------------------ collectionAsync ------------------------ @Deprecated @@ -1069,11 +1069,11 @@ public interface CacheSource extends Resourcable { @Deprecated default CompletableFuture getKeySizeAsync() { - return dbsizeAsync(); + return dbsizeAsync().thenApply(v -> v.intValue()); } @Deprecated default int getKeySize() { - return dbsize(); + return (int) dbsize(); } }