From a32586bf3b852f581bec8ecc3212d581e35105e0 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 16 Oct 2023 11:21:13 +0800
Subject: [PATCH] AbstractDataSource

---
 src/main/java/org/redkale/source/AbstractDataSource.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/main/java/org/redkale/source/AbstractDataSource.java b/src/main/java/org/redkale/source/AbstractDataSource.java
index 0dd7ebccc..e2fab9df4 100644
--- a/src/main/java/org/redkale/source/AbstractDataSource.java
+++ b/src/main/java/org/redkale/source/AbstractDataSource.java
@@ -309,6 +309,14 @@ public abstract class AbstractDataSource extends AbstractService implements Data
         return executor;
     }
 
+    protected <T> void complete(CompletableFuture<T> future, T value) {
+        getExecutor().execute(() -> future.complete(value));
+    }
+
+    protected <T> void completeExceptionally(CompletableFuture<T> future, Throwable exp) {
+        getExecutor().execute(() -> future.completeExceptionally(exp));
+    }
+
     protected String executorToString() {
         ExecutorService executor = this.sourceExecutor;
         if (executor == null) {