From 1d640f943ad1394c4d4012e1379d92ff78404a02 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Thu, 28 Dec 2017 10:14:10 +0800
Subject: [PATCH] =?UTF-8?q?CacheSource=E5=A2=9E=E5=8A=A0existsSetItem?=
 =?UTF-8?q?=E7=B3=BB=E5=88=97=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/source/CacheMemorySource.java | 33 +++++++++++++++++++
 src/org/redkale/source/CacheSource.java       | 12 +++++++
 2 files changed, 45 insertions(+)

diff --git a/src/org/redkale/source/CacheMemorySource.java b/src/org/redkale/source/CacheMemorySource.java
index 6fb19bf0e..b72eee6d8 100644
--- a/src/org/redkale/source/CacheMemorySource.java
+++ b/src/org/redkale/source/CacheMemorySource.java
@@ -667,6 +667,39 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
         return (Collection<String>) getAndRefresh(key, expireSeconds);
     }
 
+    @Override
+    public boolean existsSetItem(final String key, final V value) {
+        Collection<V> list = getCollection(key);
+        return list != null && list.contains(value);
+    }
+
+    @Override
+    public CompletableFuture<Boolean> existsSetItemAsync(final String key, final V value) {
+        return CompletableFuture.supplyAsync(() -> existsSetItem(key, value), getExecutor());
+    }
+
+    @Override
+    public boolean existsStringSetItem(final String key, final String value) {
+        Collection<String> list = getStringCollection(key);
+        return list != null && list.contains(value);
+    }
+
+    @Override
+    public CompletableFuture<Boolean> existsStringSetItemAsync(final String key, final String value) {
+        return CompletableFuture.supplyAsync(() -> existsStringSetItem(key, value), getExecutor());
+    }
+
+    @Override
+    public boolean existsLongSetItem(final String key, final long value) {
+        Collection<Long> list = getLongCollection(key);
+        return list != null && list.contains(value);
+    }
+
+    @Override
+    public CompletableFuture<Boolean> existsLongSetItemAsync(final String key, final long value) {
+        return CompletableFuture.supplyAsync(() -> existsLongSetItem(key, value), getExecutor());
+    }
+
     @Override
     @RpcMultiRun
     public Collection<Long> getLongCollectionAndRefresh(final String key, final int expireSeconds) {
diff --git a/src/org/redkale/source/CacheSource.java b/src/org/redkale/source/CacheSource.java
index 7b9da9f5d..59f553e21 100644
--- a/src/org/redkale/source/CacheSource.java
+++ b/src/org/redkale/source/CacheSource.java
@@ -66,6 +66,8 @@ public interface CacheSource<V extends Object> {
 
     public void removeListItem(final String key, final V value);
 
+    public boolean existsSetItem(final String key, final V value);
+
     public void appendSetItem(final String key, final V value);
 
     public void removeSetItem(final String key, final V value);
@@ -92,6 +94,8 @@ public interface CacheSource<V extends Object> {
 
     public void removeStringListItem(final String key, final String value);
 
+    public boolean existsStringSetItem(final String key, final String value);
+
     public void appendStringSetItem(final String key, final String value);
 
     public void removeStringSetItem(final String key, final String value);
@@ -112,6 +116,8 @@ public interface CacheSource<V extends Object> {
 
     public void removeLongListItem(final String key, final long value);
 
+    public boolean existsLongSetItem(final String key, final long value);
+
     public void appendLongSetItem(final String key, final long value);
 
     public void removeLongSetItem(final String key, final long value);
@@ -151,6 +157,8 @@ public interface CacheSource<V extends Object> {
 
     public CompletableFuture<Void> removeListItemAsync(final String key, final V value);
 
+    public CompletableFuture<Boolean> existsSetItemAsync(final String key, final V value);
+
     public CompletableFuture<Void> appendSetItemAsync(final String key, final V value);
 
     public CompletableFuture<Void> removeSetItemAsync(final String key, final V value);
@@ -177,6 +185,8 @@ public interface CacheSource<V extends Object> {
 
     public CompletableFuture<Void> removeStringListItemAsync(final String key, final String value);
 
+    public CompletableFuture<Boolean> existsStringSetItemAsync(final String key, final String value);
+
     public CompletableFuture<Void> appendStringSetItemAsync(final String key, final String value);
 
     public CompletableFuture<Void> removeStringSetItemAsync(final String key, final String value);
@@ -197,6 +207,8 @@ public interface CacheSource<V extends Object> {
 
     public CompletableFuture<Void> removeLongListItemAsync(final String key, final long value);
 
+    public CompletableFuture<Boolean> existsLongSetItemAsync(final String key, final long value);
+
     public CompletableFuture<Void> appendLongSetItemAsync(final String key, final long value);
 
     public CompletableFuture<Void> removeLongSetItemAsync(final String key, final long value);