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-22 13:05:14 +08:00
parent 68ff0f7bab
commit e79427f708
2 changed files with 32 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1120,6 +1120,28 @@ public final class CacheMemorySource extends AbstractCacheSource {
return collection == null ? 0 : collection.size();
}
@Override
public int llen(final String key) {
Collection collection = (Collection) get(key, Object.class);
return collection == null ? 0 : collection.size();
}
@Override
public int scard(final String key) {
Collection collection = (Collection) get(key, Object.class);
return collection == null ? 0 : collection.size();
}
@Override
public CompletableFuture<Integer> llenAsync(final String key) {
return CompletableFuture.supplyAsync(() -> llen(key), getExecutor());
}
@Override
public CompletableFuture<Integer> scardAsync(final String key) {
return CompletableFuture.supplyAsync(() -> scard(key), getExecutor());
}
@Override
public CompletableFuture<Integer> getCollectionSizeAsync(final String key) {
return CompletableFuture.supplyAsync(() -> getCollectionSize(key), getExecutor());

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

@@ -175,6 +175,8 @@ public interface CacheSource extends Resourcable {
public <T> Map<String, T> hmap(final String key, final Type type, int offset, int limit, String pattern);
//------------------------ list ------------------------
public int llen(final String key);
public <T> List<T> lrange(final String key, final Type componentType);
public <T> Map<String, List<T>> lrange(final Type componentType, final String... keys);
@@ -193,7 +195,9 @@ public interface CacheSource extends Resourcable {
public int lremLong(final String key, final long value);
//------------------------ set ------------------------
//------------------------ set ------------------------
public int scard(final String key);
public <T> Set<T> smembers(final String key, final Type componentType);
public <T> Map<String, Set<T>> smembers(final Type componentType, final String... keys);
@@ -425,7 +429,9 @@ public interface CacheSource extends Resourcable {
public <T> CompletableFuture<Map<String, T>> hmapAsync(final String key, final Type type, int offset, int limit, String pattern);
//------------------------ listAsync ------------------------
//------------------------ listAsync ------------------------
public CompletableFuture<Integer> llenAsync(final String key);
public <T> CompletableFuture<List<T>> lrangeAsync(final String key, final Type componentType);
public <T> CompletableFuture<Map<String, List<T>>> lrangeAsync(final Type componentType, final String... keys);
@@ -445,6 +451,8 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Integer> lremLongAsync(final String key, final long value);
//------------------------ setAsync ------------------------
public CompletableFuture<Integer> scardAsync(final String key);
public <T> CompletableFuture<Set<T>> smembersAsync(final String key, final Type componentType);
public <T> CompletableFuture<Map<String, Set<T>>> smembersAsync(final Type componentType, final String... keys);