diff --git a/src/main/java/org/redkale/source/CacheMemorySource.java b/src/main/java/org/redkale/source/CacheMemorySource.java
index 000a22f65..09aeedd50 100644
--- a/src/main/java/org/redkale/source/CacheMemorySource.java
+++ b/src/main/java/org/redkale/source/CacheMemorySource.java
@@ -295,23 +295,23 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public <T> void hsetnx(final String key, final String field, final Type type, final T value) {
-        hsetnx(CacheEntryType.MAP, key, field, value);
+    public <T> boolean hsetnx(final String key, final String field, final Type type, final T value) {
+        return hsetnx(CacheEntryType.MAP, key, field, value);
     }
 
     @Override
-    public <T> void hsetnx(final String key, final String field, final Convert convert, final Type type, final T value) {
-        hsetnx(CacheEntryType.MAP, key, field, value);
+    public <T> boolean hsetnx(final String key, final String field, final Convert convert, final Type type, final T value) {
+        return hsetnx(CacheEntryType.MAP, key, field, value);
     }
 
     @Override
-    public void hsetnxString(final String key, final String field, final String value) {
-        hsetnx(CacheEntryType.MAP, key, field, value);
+    public boolean hsetnxString(final String key, final String field, final String value) {
+        return hsetnx(CacheEntryType.MAP, key, field, value);
     }
 
     @Override
-    public void hsetnxLong(final String key, final String field, final long value) {
-        hsetnx(CacheEntryType.MAP, key, field, value);
+    public boolean hsetnxLong(final String key, final String field, final long value) {
+        return hsetnx(CacheEntryType.MAP, key, field, value);
     }
 
     @Override
@@ -541,23 +541,23 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Type type, final T value) {
-        return CompletableFuture.runAsync(() -> hsetnx(key, field, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public <T> CompletableFuture<Boolean> hsetnxAsync(final String key, final String field, final Type type, final T value) {
+        return CompletableFuture.supplyAsync(() -> hsetnx(key, field, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
-    public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Convert convert, final Type type, final T value) {
-        return CompletableFuture.runAsync(() -> hsetnx(key, field, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public <T> CompletableFuture<Boolean> hsetnxAsync(final String key, final String field, final Convert convert, final Type type, final T value) {
+        return CompletableFuture.supplyAsync(() -> hsetnx(key, field, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
-    public CompletableFuture<Void> hsetnxStringAsync(final String key, final String field, final String value) {
-        return CompletableFuture.runAsync(() -> hsetnxString(key, field, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Boolean> hsetnxStringAsync(final String key, final String field, final String value) {
+        return CompletableFuture.supplyAsync(() -> hsetnxString(key, field, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
-    public CompletableFuture<Void> hsetnxLongAsync(final String key, final String field, final long value) {
-        return CompletableFuture.runAsync(() -> hsetnxLong(key, field, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Boolean> hsetnxLongAsync(final String key, final String field, final long value) {
+        return CompletableFuture.supplyAsync(() -> hsetnxLong(key, field, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
@@ -701,17 +701,19 @@ public final class CacheMemorySource extends AbstractCacheSource {
         }
     }
 
-    protected void setnx(CacheEntryType cacheType, String key, Object value) {
+    protected boolean setnx(CacheEntryType cacheType, String key, Object value) {
         if (key == null) {
-            return;
+            return false;
         }
         CacheEntry entry = container.get(key);
         if (entry == null) {
             entry = new CacheEntry(cacheType, key, value, null, null, null);
             container.putIfAbsent(key, entry);
+            return true;
         } else {
             entry.expireSeconds = 0;
             entry.lastAccessed = (int) (System.currentTimeMillis() / 1000);
+            return false;
         }
     }
 
@@ -731,18 +733,20 @@ public final class CacheMemorySource extends AbstractCacheSource {
         }
     }
 
-    protected void hsetnx(CacheEntryType cacheType, String key, String field, Object value) {
+    protected boolean hsetnx(CacheEntryType cacheType, String key, String field, Object value) {
         if (key == null) {
-            return;
+            return false;
         }
         CacheEntry entry = container.get(key);
         if (entry == null) {
             entry = new CacheEntry(CacheEntryType.MAP, key, value, null, null, new ConcurrentHashMap<>());
             container.putIfAbsent(key, entry);
             entry.mapValue.putIfAbsent(field, value);
+            return true;
         } else {
             entry.expireSeconds = 0;
             entry.lastAccessed = (int) (System.currentTimeMillis() / 1000);
+            return false;
         }
     }
 
@@ -788,13 +792,13 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public <T> void setnx(String key, Type type, T value) {
-        setnx(CacheEntryType.OBJECT, key, value);
+    public <T> boolean setnx(String key, Type type, T value) {
+        return setnx(CacheEntryType.OBJECT, key, value);
     }
 
     @Override
-    public <T> void setnx(String key, Convert convert, Type type, T value) {
-        setnx(CacheEntryType.OBJECT, key, value);
+    public <T> boolean setnx(String key, Convert convert, Type type, T value) {
+        return setnx(CacheEntryType.OBJECT, key, value);
     }
 
     @Override
@@ -817,8 +821,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public void setnxString(String key, String value) {
-        setnx(CacheEntryType.STRING, key, value);
+    public boolean setnxString(String key, String value) {
+        return setnx(CacheEntryType.STRING, key, value);
     }
 
     @Override
@@ -827,8 +831,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public void setnxLong(String key, long value) {
-        setnx(CacheEntryType.LONG, key, value);
+    public boolean setnxLong(String key, long value) {
+        return setnx(CacheEntryType.LONG, key, value);
     }
 
     @Override
@@ -852,13 +856,13 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public <T> CompletableFuture<Void> setnxAsync(String key, Type type, T value) {
-        return CompletableFuture.runAsync(() -> setnx(key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public <T> CompletableFuture<Boolean> setnxAsync(String key, Type type, T value) {
+        return CompletableFuture.supplyAsync(() -> setnx(key, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
-    public <T> CompletableFuture<Void> setnxAsync(String key, Convert convert, Type type, T value) {
-        return CompletableFuture.runAsync(() -> setnx(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public <T> CompletableFuture<Boolean> setnxAsync(String key, Convert convert, Type type, T value) {
+        return CompletableFuture.supplyAsync(() -> setnx(key, convert, type, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
@@ -877,8 +881,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public CompletableFuture<Void> setnxStringAsync(String key, String value) {
-        return CompletableFuture.runAsync(() -> setnxString(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Boolean> setnxStringAsync(String key, String value) {
+        return CompletableFuture.supplyAsync(() -> setnxString(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
@@ -892,8 +896,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public CompletableFuture<Void> setnxLongAsync(String key, long value) {
-        return CompletableFuture.runAsync(() -> setnxLong(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Boolean> setnxLongAsync(String key, long value) {
+        return CompletableFuture.supplyAsync(() -> setnxLong(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     protected void set(CacheEntryType cacheType, int expireSeconds, String key, Object value) {
@@ -1758,13 +1762,13 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public void setnxBytes(final String key, final byte[] value) {
-        setnx(CacheEntryType.BYTES, key, value);
+    public boolean setnxBytes(final String key, final byte[] value) {
+        return setnx(CacheEntryType.BYTES, key, value);
     }
 
     @Override
-    public CompletableFuture<Void> setnxBytesAsync(final String key, byte[] value) {
-        return CompletableFuture.runAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Boolean> setnxBytesAsync(final String key, byte[] value) {
+        return CompletableFuture.supplyAsync(() -> setnxBytes(key, value), getExecutor()).whenComplete(futureCompleteConsumer);
     }
 
     @Override
diff --git a/src/main/java/org/redkale/source/CacheSource.java b/src/main/java/org/redkale/source/CacheSource.java
index a3e42a015..1ccf8ea9e 100644
--- a/src/main/java/org/redkale/source/CacheSource.java
+++ b/src/main/java/org/redkale/source/CacheSource.java
@@ -125,15 +125,15 @@ public interface CacheSource extends Resourcable {
     public void setBytes(final String key, final byte[] value);
 
     //------------------------ setnx ------------------------
-    public <T> void setnx(final String key, final Type type, final T value);
+    public <T> boolean setnx(final String key, final Type type, final T value);
 
-    public <T> void setnx(final String key, final Convert convert, final Type type, final T value);
+    public <T> boolean setnx(final String key, final Convert convert, final Type type, final T value);
 
-    public void setnxString(final String key, final String value);
+    public boolean setnxString(final String key, final String value);
 
-    public void setnxLong(final String key, final long value);
+    public boolean setnxLong(final String key, final long value);
 
-    public void setnxBytes(final String key, final byte[] value);
+    public boolean setnxBytes(final String key, final byte[] value);
 
     //------------------------ setex ------------------------
     public <T> void setex(final String key, final int expireSeconds, final Type type, final T value);
@@ -180,13 +180,13 @@ public interface CacheSource extends Resourcable {
     public void hsetLong(final String key, final String field, final long value);
 
     //------------------------ hsetnx ------------------------
-    public <T> void hsetnx(final String key, final String field, final Type type, final T value);
+    public <T> boolean hsetnx(final String key, final String field, final Type type, final T value);
 
-    public <T> void hsetnx(final String key, final String field, final Convert convert, final Type type, final T value);
+    public <T> boolean hsetnx(final String key, final String field, final Convert convert, final Type type, final T value);
 
-    public void hsetnxString(final String key, final String field, final String value);
+    public boolean hsetnxString(final String key, final String field, final String value);
 
-    public void hsetnxLong(final String key, final String field, final long value);
+    public boolean hsetnxLong(final String key, final String field, final long value);
 
     //------------------------ hxxx ------------------------
     public int hdel(final String key, String... fields);
@@ -430,15 +430,15 @@ public interface CacheSource extends Resourcable {
     public CompletableFuture<Void> setBytesAsync(final String key, final byte[] value);
 
     //------------------------ setnxAsync ------------------------
-    public <T> CompletableFuture<Void> setnxAsync(final String key, final Type type, final T value);
+    public <T> CompletableFuture<Boolean> setnxAsync(final String key, final Type type, final T value);
 
-    public <T> CompletableFuture<Void> setnxAsync(final String key, final Convert convert, final Type type, final T value);
+    public <T> CompletableFuture<Boolean> setnxAsync(final String key, final Convert convert, final Type type, final T value);
 
-    public CompletableFuture<Void> setnxStringAsync(final String key, final String value);
+    public CompletableFuture<Boolean> setnxStringAsync(final String key, final String value);
 
-    public CompletableFuture<Void> setnxLongAsync(final String key, long value);
+    public CompletableFuture<Boolean> setnxLongAsync(final String key, long value);
 
-    public CompletableFuture<Void> setnxBytesAsync(final String key, final byte[] value);
+    public CompletableFuture<Boolean> setnxBytesAsync(final String key, final byte[] value);
 
     //------------------------ setexAsync ------------------------
     public <T> CompletableFuture<Void> setexAsync(final String key, final int expireSeconds, final Type type, final T value);
@@ -485,13 +485,13 @@ public interface CacheSource extends Resourcable {
     public CompletableFuture<Void> hsetLongAsync(final String key, final String field, final long value);
 
     //------------------------ hsetnxAsync ------------------------
-    public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Type type, final T value);
+    public <T> CompletableFuture<Boolean> hsetnxAsync(final String key, final String field, final Type type, final T value);
 
-    public <T> CompletableFuture<Void> hsetnxAsync(final String key, final String field, final Convert convert, final Type type, final T value);
+    public <T> CompletableFuture<Boolean> hsetnxAsync(final String key, final String field, final Convert convert, final Type type, final T value);
 
-    public CompletableFuture<Void> hsetnxStringAsync(final String key, final String field, final String value);
+    public CompletableFuture<Boolean> hsetnxStringAsync(final String key, final String field, final String value);
 
-    public CompletableFuture<Void> hsetnxLongAsync(final String key, final String field, final long value);
+    public CompletableFuture<Boolean> hsetnxLongAsync(final String key, final String field, final long value);
 
     //------------------------ hxxxAsync ------------------------
     public CompletableFuture<Integer> hdelAsync(final String key, String... fields);