diff --git a/src/main/java/org/redkale/source/CacheMemorySource.java b/src/main/java/org/redkale/source/CacheMemorySource.java
index 001848b13..69cd5316b 100644
--- a/src/main/java/org/redkale/source/CacheMemorySource.java
+++ b/src/main/java/org/redkale/source/CacheMemorySource.java
@@ -840,9 +840,13 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public int del(String key) {
-        if (key == null) return 0;
-        return container.remove(key) == null ? 0 : 1;
+    public int del(final String... keys) {
+        if (keys == null) return 0;
+        int count = 0;
+        for (String key : keys) {
+            count += container.remove(key) == null ? 0 : 1;
+        }
+        return count;
     }
 
     @Override
@@ -896,8 +900,8 @@ public final class CacheMemorySource extends AbstractCacheSource {
     }
 
     @Override
-    public CompletableFuture<Integer> delAsync(final String key) {
-        return CompletableFuture.supplyAsync(() -> del(key), getExecutor()).whenComplete(futureCompleteConsumer);
+    public CompletableFuture<Integer> delAsync(final String... keys) {
+        return CompletableFuture.supplyAsync(() -> del(keys), 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 e16ca04ef..d494653fc 100644
--- a/src/main/java/org/redkale/source/CacheSource.java
+++ b/src/main/java/org/redkale/source/CacheSource.java
@@ -122,7 +122,7 @@ public interface CacheSource extends Resourcable {
 
     public void expire(final String key, final int seconds);
 
-    public int del(final String key);
+    public int del(final String... keys);
 
     public long incr(final String key);
 
@@ -396,7 +396,7 @@ public interface CacheSource extends Resourcable {
 
     public CompletableFuture<Void> expireAsync(final String key, final int seconds);
 
-    public CompletableFuture<Integer> delAsync(final String key);
+    public CompletableFuture<Integer> delAsync(final String... keys);
 
     public CompletableFuture<Long> incrAsync(final String key);