优化CacheSource部分方法名

This commit is contained in:
Redkale
2022-12-21 16:43:32 +08:00
parent d3236f57d2
commit c48ba58d55
3 changed files with 47 additions and 17 deletions

View File

@@ -243,7 +243,7 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
@Override
public void deregister(Application application) {
String serviceName = generateApplicationServiceName();
source.remove(serviceName);
source.del(serviceName);
}
@Override
@@ -282,7 +282,7 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
}
}
}
source.hremove(serviceName, serviceid);
source.hdel(serviceName, serviceid);
if (realcanceled && currEntry != null) currEntry.canceled = true;
if (!"mqtp".equals(protocol) && currEntry != null && currEntry.submqtp) {
deregister(ns, "mqtp", service, realcanceled);

View File

@@ -141,7 +141,7 @@ public final class CacheMemorySource extends AbstractCacheSource {
//----------- hxxx --------------
@Override
public int hremove(final String key, String... fields) {
public int hdel(final String key, String... fields) {
int count = 0;
CacheEntry entry = container.get(key);
if (entry == null || entry.mapValue == null) return 0;
@@ -387,8 +387,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
//----------- hxxx --------------
@Override
public CompletableFuture<Integer> hremoveAsync(final String key, String... fields) {
return CompletableFuture.supplyAsync(() -> hremove(key, fields), getExecutor());
public CompletableFuture<Integer> hdelAsync(final String key, String... fields) {
return CompletableFuture.supplyAsync(() -> hdel(key, fields), getExecutor());
}
@Override
@@ -840,7 +840,7 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public void setExpireSeconds(String key, int expireSeconds) {
public void expire(String key, int expireSeconds) {
if (key == null) return;
CacheEntry entry = container.get(key);
if (entry == null) return;
@@ -848,12 +848,12 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public CompletableFuture<Void> setExpireSecondsAsync(final String key, final int expireSeconds) {
return CompletableFuture.runAsync(() -> setExpireSeconds(key, expireSeconds), getExecutor()).whenComplete(futureCompleteConsumer);
public CompletableFuture<Void> expireAsync(final String key, final int expireSeconds) {
return CompletableFuture.runAsync(() -> expire(key, expireSeconds), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override
public int remove(String key) {
public int del(String key) {
if (key == null) return 0;
return container.remove(key) == null ? 0 : 1;
}
@@ -909,8 +909,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
}
@Override
public CompletableFuture<Integer> removeAsync(final String key) {
return CompletableFuture.supplyAsync(() -> remove(key), getExecutor()).whenComplete(futureCompleteConsumer);
public CompletableFuture<Integer> delAsync(final String key) {
return CompletableFuture.supplyAsync(() -> del(key), getExecutor()).whenComplete(futureCompleteConsumer);
}
@Override

View File

@@ -41,7 +41,12 @@ public interface CacheSource extends Resourcable {
public <T> T getAndRefresh(final String key, final int expireSeconds, final Type type);
//----------- hxxx --------------
public int hremove(final String key, String... fields);
@Deprecated
default int hremove(final String key, String... fields) {
return hdel(key, fields);
}
public int hdel(final String key, String... fields);
public List<String> hkeys(final String key);
@@ -116,9 +121,19 @@ public interface CacheSource extends Resourcable {
public <T> void set(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public void setExpireSeconds(final String key, final int expireSeconds);
@Deprecated
default void setExpireSeconds(final String key, final int expireSeconds) {
expire(key, expireSeconds);
}
public int remove(final String key);
public void expire(final String key, final int seconds);
@Deprecated
default int remove(final String key) {
return del(key);
}
public int del(final String key);
public long incr(final String key);
@@ -277,9 +292,19 @@ public interface CacheSource extends Resourcable {
public <T> CompletableFuture<Void> setAsync(final int expireSeconds, final String key, final Convert convert, final Type type, final T value);
public CompletableFuture<Void> setExpireSecondsAsync(final String key, final int expireSeconds);
@Deprecated
default CompletableFuture<Void> setExpireSecondsAsync(final String key, final int expireSeconds) {
return expireAsync(key, expireSeconds);
}
public CompletableFuture<Integer> removeAsync(final String key);
public CompletableFuture<Void> expireAsync(final String key, final int seconds);
@Deprecated
default CompletableFuture<Integer> removeAsync(final String key) {
return delAsync(key);
}
public CompletableFuture<Integer> delAsync(final String key);
public CompletableFuture<Long> incrAsync(final String key);
@@ -290,7 +315,12 @@ public interface CacheSource extends Resourcable {
public CompletableFuture<Long> decrAsync(final String key, long num);
//----------- hxxx --------------
public CompletableFuture<Integer> hremoveAsync(final String key, String... fields);
@Deprecated
default CompletableFuture<Integer> hremoveAsync(final String key, String... fields) {
return hdelAsync(key, fields);
}
public CompletableFuture<Integer> hdelAsync(final String key, String... fields);
public CompletableFuture<List<String>> hkeysAsync(final String key);