src/org/redkale/boot/NodeServer.java

@@ -116,7 +116,7 @@ public abstract class NodeServer {
                 if (context == null) {
                     t.run();
                 } else {
-                    context.submit(t);
+                    context.submitAsync(t);
                 }
             }
 

src/org/redkale/net/Context.java

@@ -109,8 +109,12 @@ public class Context {
         return charset;
     }
 
-    public void submit(Runnable r) {
-        executor.submit(r);
+    public Future<?> submitAsync(Runnable r) {
+        return executor.submit(r);
+    }
+
+    public void runAsync(Runnable r) {
+        executor.execute(r);
     }
 
     public int getBufferCapacity() {

src/org/redkale/net/ProtocolServer.java

@@ -92,7 +92,7 @@ public abstract class ProtocolServer {
                             SocketAddress address = serchannel.receive(buffer);
                             buffer.flip();
                             AsyncConnection conn = AsyncConnection.create(serchannel, address, false, readTimeoutSecond, writeTimeoutSecond);
-                            context.submit(new PrepareRunner(context, conn, buffer));
+                            context.runAsync(new PrepareRunner(context, conn, buffer));
                         } catch (Exception e) {
                             context.offerBuffer(buffer);
                         }
@@ -160,7 +160,7 @@ public abstract class ProtocolServer {
                 @Override
                 public void completed(final AsynchronousSocketChannel channel, Void attachment) {
                     serchannel.accept(null, this);
-                    context.submit(new PrepareRunner(context, AsyncConnection.create(channel, null, context.readTimeoutSecond, context.writeTimeoutSecond), null));
+                    context.submitAsync(new PrepareRunner(context, AsyncConnection.create(channel, null, context.readTimeoutSecond, context.writeTimeoutSecond), null));
                 }
 
                 @Override

src/org/redkale/net/Response.java

@@ -117,7 +117,7 @@ public abstract class Response<C extends Context, R extends Request<C>> {
         request.recycle();
         if (channel != null) {
             if (keepAlive) {
-                this.context.submit(new PrepareRunner(context, channel, null));
+                this.context.runAsync(new PrepareRunner(context, channel, null));
             } else {
                 try {
                     if (channel.isOpen()) channel.close();

src/org/redkale/net/WorkThread.java

@@ -25,8 +25,8 @@ public class WorkThread extends Thread {
         this.setDaemon(true);
     }
 
-    public Future<?> submit(Runnable runner) {
-        return executor.submit(runner);
+    public void runAsync(Runnable runner) {
+        executor.execute(runner);
     }
 
     public ExecutorService getExecutor() {

src/org/redkale/net/http/WebSocketServlet.java

@@ -146,7 +146,7 @@ public abstract class WebSocketServlet extends HttpServlet implements Resourcabl
                 }
                 webSocket._groupid = groupid;
                 engine.add(webSocket);
-                context.submit(new WebSocketRunner(context, webSocket, response.removeChannel(), wsbinary));
+                context.runAsync(new WebSocketRunner(context, webSocket, response.removeChannel(), wsbinary));
                 response.finish(true);
             }
 

src/org/redkale/service/AbstractService.java

@@ -14,12 +14,13 @@ import org.redkale.net.WorkThread;
  */
 public abstract class AbstractService implements Service {
 
-    protected Future<?> submit(Runnable runner) {
+    protected void execute(Runnable runner) {
         Thread thread = Thread.currentThread();
         if (thread instanceof WorkThread) {
-            return ((WorkThread) thread).submit(runner);
+            ((WorkThread) thread).runAsync(runner);
+        } else {
+            ForkJoinPool.commonPool().execute(runner);
         }
-        return ForkJoinPool.commonPool().submit(runner);
     }
 
     protected ExecutorService getExecutor() {

src/org/redkale/source/CacheMemorySource.java

@@ -197,9 +197,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Boolean> existsAsync(final K key) {
-        CompletableFuture<Boolean> future = new CompletableFuture();
-        future.complete(exists(key));
-        return future;
+        return CompletableFuture.supplyAsync(() -> exists(key));
     }
 
     @Override
@@ -220,9 +218,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<V> getAsync(final K key) {
-        CompletableFuture<V> future = new CompletableFuture();
-        future.complete(get(key));
-        return future;
+        return CompletableFuture.supplyAsync(() -> get(key));
     }
 
     @Override
@@ -246,9 +242,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<V> getAndRefreshAsync(final K key, final int expireSeconds) {
-        CompletableFuture<V> future = new CompletableFuture();
-        future.complete(getAndRefresh(key, expireSeconds));
-        return future;
+        return CompletableFuture.supplyAsync(() -> getAndRefresh(key, expireSeconds));
     }
 
     @Override
@@ -269,10 +263,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> refreshAsync(final K key, final int expireSeconds) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        refresh(key, expireSeconds);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> refresh(key, expireSeconds));
     }
 
     @Override
@@ -298,10 +289,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> setAsync(K key, V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        set(key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> set(key, value));
     }
 
     @Override
@@ -327,10 +315,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> setAsync(int expireSeconds, K key, V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        set(expireSeconds, key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> set(expireSeconds, key, value));
     }
 
     @Override
@@ -350,10 +335,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> setExpireSecondsAsync(final K key, final int expireSeconds) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        setExpireSeconds(key, expireSeconds);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> setExpireSeconds(key, expireSeconds));
     }
 
     @Override
@@ -371,10 +353,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> removeAsync(final K key) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        remove(key);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> remove(key));
     }
 
     @Override
@@ -390,9 +369,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Collection<V>> getCollectionAsync(final K key) {
-        CompletableFuture<Collection<V>> future = new CompletableFuture();
-        future.complete((Collection<V>) get(key));
-        return future;
+        return CompletableFuture.supplyAsync(() -> getCollection(key));
     }
 
     @Override
@@ -408,9 +385,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Collection<V>> getCollectionAndRefreshAsync(final K key, final int expireSeconds) {
-        CompletableFuture<Collection<V>> future = new CompletableFuture();
-        future.complete((Collection<V>) getAndRefresh(key, expireSeconds));
-        return future;
+        return CompletableFuture.supplyAsync(() -> getCollectionAndRefresh(key, expireSeconds));
     }
 
     @Override
@@ -437,10 +412,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> appendListItemAsync(final K key, final V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        appendListItem(key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> appendListItem(key, value));
     }
 
     @Override
@@ -460,10 +432,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> removeListItemAsync(final K key, final V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        removeListItem(key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> removeListItem(key, value));
     }
 
     @Override
@@ -490,10 +459,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> appendSetItemAsync(final K key, final V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        appendSetItem(key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> appendSetItem(key, value));
     }
 
     @Override
@@ -513,10 +479,7 @@ public class CacheMemorySource<K extends Serializable, V extends Object> extends
 
     @Override
     public CompletableFuture<Void> removeSetItemAsync(final K key, final V value) {
-        CompletableFuture<Void> future = new CompletableFuture();
-        removeSetItem(key, value);
-        future.complete(null);
-        return future;
+        return CompletableFuture.runAsync(() -> removeSetItem(key, value));
     }
 
     @Override

src/org/redkale/source/DataJdbcSource.java

@@ -9,6 +9,7 @@ import java.io.*;
 import java.net.URL;
 import java.sql.*;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.*;
 import java.util.logging.*;
@@ -144,6 +145,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Void> insertAsync(@RpcCall(DataCallArrayAttribute.class) T... values) {
+        return CompletableFuture.runAsync(() -> insert(values));
+    }
+
     @Override
     public <T> void insertAsync(final AsyncHandler<Void, T[]> handler, @RpcAttachment @RpcCall(DataCallArrayAttribute.class) final T... values) {
         insert(values);
@@ -323,6 +329,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> deleteAsync(final T... values) {
+        return CompletableFuture.supplyAsync(() -> delete(values));
+    }
+
     @Override
     public <T> void deleteAsync(final AsyncHandler<Integer, T[]> handler, @RpcAttachment final T... values) {
         int rs = delete(values);
@@ -354,6 +365,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Serializable... ids) {
+        return CompletableFuture.supplyAsync(() -> delete(clazz, ids));
+    }
+
     @Override
     public <T> void deleteAsync(final AsyncHandler<Integer, Serializable[]> handler, final Class<T> clazz, @RpcAttachment final Serializable... ids) {
         int rs = delete(clazz, ids);
@@ -408,6 +424,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> delete(clazz, node));
+    }
+
     @Override
     public <T> void deleteAsync(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         int rs = delete(clazz, node);
@@ -428,6 +449,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> deleteAsync(final Class<T> clazz, final Flipper flipper, FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> delete(clazz, flipper, node));
+    }
+
     @Override
     public <T> void deleteAsync(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment FilterNode node) {
         int rs = delete(clazz, flipper, node);
@@ -451,7 +477,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
                 }
                 String sql = "DELETE " + (this.readPool.isMysql() ? "a" : "") + " FROM " + info.getTable(node) + " a" + (join1 == null ? "" : (", " + join1))
                     + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2)))) + info.createSQLOrderby(flipper)
+                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2)))) + info.createSQLOrderby(flipper)
                     + ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()));
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " delete sql=" + sql);
                 conn.setReadOnly(false);
@@ -520,6 +546,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateAsync(final T... values) {
+        return CompletableFuture.supplyAsync(() -> update(values));
+    }
+
     @Override
     public <T> void updateAsync(final AsyncHandler<Integer, T[]> handler, @RpcAttachment final T... values) {
         int rs = update(values);
@@ -617,6 +648,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnupdateColumnAsync(final Class<T> clazz, final Serializable id, final String column, final Serializable value) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, id, column, value));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, final Serializable id, final String column, final Serializable value) {
         int rs = updateColumn(clazz, id, column, value);
@@ -685,6 +721,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final String column, final Serializable value, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, column, value, node));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, final String column, final Serializable value, @RpcAttachment final FilterNode node) {
         int rs = updateColumn(clazz, column, value, node);
@@ -710,7 +751,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
                     String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1))
                         + " SET " + info.getSQLColumn("a", column) + " = ?"
                         + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                            : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
                     if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                     conn.setReadOnly(false);
                     Blob blob = conn.createBlob();
@@ -723,7 +764,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
                     String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1))
                         + " SET " + info.getSQLColumn("a", column) + " = " + info.formatToString(value)
                         + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                            : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
                     if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                     conn.setReadOnly(false);
                     final Statement stmt = conn.createStatement();
@@ -768,6 +809,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final Serializable id, final ColumnValue... values) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, id, values));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable id, final ColumnValue... values) {
         int rs = updateColumn(clazz, id, values);
@@ -855,6 +901,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, node, values));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node, final ColumnValue... values) {
         int rs = updateColumn(clazz, node, values);
@@ -886,6 +937,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final Class<T> clazz, final FilterNode node, final Flipper flipper, final ColumnValue... values) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(clazz, node, flipper, values));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node, final Flipper flipper, final ColumnValue... values) {
         int rs = updateColumn(clazz, node, flipper, values);
@@ -931,7 +987,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
                 }
                 String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1)) + " SET " + setsql
                     + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
                 //注：LIMIT 仅支持MySQL 且在多表关联式会异常， 该BUG尚未解决
                 sql += info.createSQLOrderby(flipper) + ((flipper == null || flipper.getLimit() < 1) ? "" : (" LIMIT " + flipper.getLimit()));
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
@@ -968,12 +1024,33 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return updateColumn(bean, SelectColumn.createIncludes(columns));
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final String... columns) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(bean, columns));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, T> handler, @RpcAttachment final T bean, final String... columns) {
         int rs = updateColumn(bean, columns);
         if (handler != null) handler.completed(rs, bean);
     }
 
+    @Override
+    public <T> int updateColumn(final T bean, final FilterNode node, final String... columns) {
+        return updateColumn(bean, node, SelectColumn.createIncludes(columns));
+    }
+
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final String... columns) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(bean, node, columns));
+    }
+
+    @Override
+    public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final T bean, @RpcAttachment final FilterNode node, final String... columns) {
+        int rs = updateColumn(bean, node, columns);
+        if (handler != null) handler.completed(rs, node);
+    }
+
     @Override
     public <T> int updateColumn(final T bean, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
@@ -988,6 +1065,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final SelectColumn selects) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(bean, selects));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, T> handler, @RpcAttachment final T bean, final SelectColumn selects) {
         int rs = updateColumn(bean, selects);
@@ -1051,17 +1133,6 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
-    @Override
-    public <T> int updateColumn(final T bean, final FilterNode node, final String... columns) {
-        return updateColumn(bean, node, SelectColumn.createIncludes(columns));
-    }
-
-    @Override
-    public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final T bean, @RpcAttachment final FilterNode node, final String... columns) {
-        int rs = updateColumn(bean, node, columns);
-        if (handler != null) handler.completed(rs, node);
-    }
-
     @Override
     public <T> int updateColumn(final T bean, final FilterNode node, final SelectColumn selects) {
         final EntityInfo<T> info = loadEntityInfo((Class<T>) bean.getClass());
@@ -1076,6 +1147,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Integer> updateColumnAsync(final T bean, final FilterNode node, final SelectColumn selects) {
+        return CompletableFuture.supplyAsync(() -> updateColumn(bean, node, selects));
+    }
+
     @Override
     public <T> void updateColumnAsync(final AsyncHandler<Integer, FilterNode> handler, final T bean, @RpcAttachment final FilterNode node, final SelectColumn selects) {
         int rs = updateColumn(bean, node, selects);
@@ -1121,7 +1197,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
                 }
                 String sql = "UPDATE " + info.getTable(node) + " a " + (join1 == null ? "" : (", " + join1)) + " SET " + setsql
                     + ((where == null || where.length() == 0) ? (join2 == null ? "" : (" WHERE " + join2))
-                        : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
+                    : (" WHERE " + where + (join2 == null ? "" : (" AND " + join2))));
                 if (debug.get() && info.isLoggable(Level.FINEST)) logger.finest(info.getType().getSimpleName() + " update sql=" + sql);
                 conn.setReadOnly(false);
                 if (blobs != null) {
@@ -1184,6 +1260,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberResult(entityClass, func, null, column, (FilterNode) null);
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column));
+    }
+
     @Override
     public void getNumberResultAsync(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, @RpcAttachment final String column) {
         Number rs = getNumberResult(entityClass, func, column);
@@ -1195,6 +1276,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberResult(entityClass, func, null, column, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column, bean));
+    }
+
     @Override
     public <B extends FilterBean> void getNumberResultAsync(final AsyncHandler<Number, B> handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final B bean) {
         Number rs = getNumberResult(entityClass, func, column, bean);
@@ -1206,6 +1292,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberResult(entityClass, func, null, column, node);
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final String column, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, column, node));
+    }
+
     @Override
     public void getNumberResultAsync(final AsyncHandler<Number, FilterNode> handler, final Class entityClass, final FilterFunc func, final String column, @RpcAttachment final FilterNode node) {
         Number rs = getNumberResult(entityClass, func, column, node);
@@ -1217,6 +1308,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberResult(entityClass, func, defVal, column, (FilterNode) null);
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column));
+    }
+
     @Override
     public void getNumberResultAsync(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column) {
         Number rs = getNumberResult(entityClass, func, defVal, column);
@@ -1228,16 +1324,37 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberResult(entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column, bean));
+    }
+
     @Override
     public void getNumberResultAsync(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterBean bean) {
         getNumberResultAsync(handler, entityClass, func, defVal, column, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public CompletableFuture<Number> getNumberResultAsync(final Class entityClass, final FilterFunc func, final Number defVal, final String column, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> getNumberResult(entityClass, func, defVal, column, node));
+    }
+
+    @Override
+    public void getNumberResultAsync(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterNode node) {
+        Number rs = getNumberResult(entityClass, func, defVal, column, node);
+        if (handler != null) handler.completed(rs, column);
+    }
+
     @Override
     public <N extends Number> Map<String, N> getNumberMap(final Class entityClass, final FilterFuncColumn... columns) {
         return getNumberMap(entityClass, (FilterNode) null, columns);
     }
 
+    @Override
+    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterFuncColumn... columns) {
+        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, columns));
+    }
+
     @Override
     public <N extends Number> void getNumberMapAsync(final AsyncHandler<Map<String, N>, FilterFuncColumn[]> handler, final Class entityClass, @RpcAttachment final FilterFuncColumn... columns) {
         Map<String, N> rs = getNumberMap(entityClass, columns);
@@ -1249,6 +1366,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return getNumberMap(entityClass, FilterNodeBean.createFilterNode(bean), columns);
     }
 
+    @Override
+    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterBean bean, final FilterFuncColumn... columns) {
+        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, bean, columns));
+    }
+
     @Override
     public <N extends Number, B extends FilterBean> void getNumberMapAsync(final AsyncHandler<Map<String, N>, B> handler, final Class entityClass, @RpcAttachment final B bean, final FilterFuncColumn... columns) {
         Map<String, N> rs = getNumberMap(entityClass, bean, columns);
@@ -1320,6 +1442,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <N extends Number> CompletableFuture<Map<String, N>> getNumberMapAsync(final Class entityClass, final FilterNode node, final FilterFuncColumn... columns) {
+        return CompletableFuture.supplyAsync(() -> getNumberMap(entityClass, node, columns));
+    }
+
     @Override
     public <N extends Number> void getNumberMapAsync(final AsyncHandler<Map<String, N>, FilterNode> handler, final Class entityClass, @RpcAttachment final FilterNode node, final FilterFuncColumn... columns) {
         Map<String, N> rs = getNumberMap(entityClass, node, columns);
@@ -1363,18 +1490,17 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
-    @Override
-    public void getNumberResultAsync(final AsyncHandler<Number, String> handler, final Class entityClass, final FilterFunc func, final Number defVal, @RpcAttachment final String column, final FilterNode node) {
-        Number rs = getNumberResult(entityClass, func, defVal, column, node);
-        if (handler != null) handler.completed(rs, column);
-    }
-
     //-----------------------queryColumnMapAsync-----------------------------
     @Override
     public <T, K extends Serializable, N extends Number> Map<K, N> queryColumnMap(final Class<T> entityClass, final String keyColumn, FilterFunc func, final String funcColumn) {
         return queryColumnMap(entityClass, keyColumn, func, funcColumn, (FilterNode) null);
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn) {
+        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn));
+    }
+
     @Override
     public <T, K extends Serializable, N extends Number> void queryColumnMapAsync(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn) {
         Map<K, N> rs = queryColumnMap(entityClass, keyColumn, func, funcColumn);
@@ -1386,6 +1512,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnMap(entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn, bean));
+    }
+
     @Override
     public <T, K extends Serializable, N extends Number> void queryColumnMapAsync(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterBean bean) {
         queryColumnMapAsync(handler, entityClass, keyColumn, func, funcColumn, FilterNodeBean.createFilterNode(bean));
@@ -1430,6 +1561,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T, K extends Serializable, N extends Number> CompletableFuture<Map<K, N>> queryColumnMapAsync(final Class<T> entityClass, final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryColumnMap(entityClass, keyColumn, func, funcColumn, node));
+    }
+
     @Override
     public <T, K extends Serializable, N extends Number> void queryColumnMapAsync(final AsyncHandler<Map<K, N>, String> handler, final Class<T> entityClass, @RpcAttachment final String keyColumn, final FilterFunc func, final String funcColumn, final FilterNode node) {
         Map<K, N> rs = queryColumnMap(entityClass, keyColumn, func, funcColumn, node);
@@ -1451,6 +1587,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return find(clazz, (SelectColumn) null, pk);
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final Serializable pk) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, pk));
+    }
+
     @Override
     public <T> void findAsync(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable pk) {
         T rs = find(clazz, pk);
@@ -1489,6 +1630,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final Serializable pk) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, selects, pk));
+    }
+
     @Override
     public <T> void findAsync(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, SelectColumn selects, @RpcAttachment final Serializable pk) {
         T rs = find(clazz, selects, pk);
@@ -1500,6 +1646,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return find(clazz, null, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final String column, final Serializable key) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, column, key));
+    }
+
     @Override
     public <T> void findAsync(final AsyncHandler<T, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
         T rs = find(clazz, column, key);
@@ -1511,6 +1662,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return find(clazz, null, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void findAsync(final AsyncHandler<T, B> handler, final Class<T> clazz, @RpcAttachment final B bean) {
         T rs = find(clazz, bean);
@@ -1522,6 +1678,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return find(clazz, null, node);
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, node));
+    }
+
     @Override
     public <T> void findAsync(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         T rs = find(clazz, node);
@@ -1533,6 +1694,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return find(clazz, selects, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, selects, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void findAsync(final AsyncHandler<T, B> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final B bean) {
         T rs = find(clazz, selects, bean);
@@ -1571,6 +1737,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<T> findAsync(final Class<T> clazz, final SelectColumn selects, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> find(clazz, selects, node));
+    }
+
     @Override
     public <T> void findAsync(final AsyncHandler<T, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) {
         T rs = find(clazz, selects, node);
@@ -1582,6 +1753,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return findColumn(clazz, column, null, pk);
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable pk) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, pk));
+    }
+
     @Override
     public <T> void findColumnAsync(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable pk) {
         Serializable rs = findColumn(clazz, column, pk);
@@ -1593,6 +1769,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return findColumn(clazz, column, null, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void findColumnAsync(final AsyncHandler<Serializable, B> handler, final Class<T> clazz, final String column, @RpcAttachment final B bean) {
         Serializable rs = findColumn(clazz, column, bean);
@@ -1604,6 +1785,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return findColumn(clazz, column, null, node);
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, node));
+    }
+
     @Override
     public <T> void findColumnAsync(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, @RpcAttachment final FilterNode node) {
         Serializable rs = findColumn(clazz, column, node);
@@ -1650,6 +1836,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final Serializable pk) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, pk));
+    }
+
     @Override
     public <T> void findColumnAsync(final AsyncHandler<Serializable, Serializable> handler, final Class<T> clazz, final String column, final Serializable defValue, @RpcAttachment final Serializable pk) {
         Serializable rs = findColumn(clazz, column, defValue, pk);
@@ -1661,6 +1852,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return findColumn(clazz, column, defValue, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void findColumnAsync(final AsyncHandler<Serializable, B> handler, final Class<T> clazz, final String column, final Serializable defValue, @RpcAttachment final B bean) {
         Serializable rs = findColumn(clazz, column, defValue, bean);
@@ -1707,6 +1903,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Serializable> findColumnAsync(final Class<T> clazz, final String column, final Serializable defValue, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> findColumn(clazz, column, defValue, node));
+    }
+
     @Override
     public <T> void findColumnAsync(final AsyncHandler<Serializable, FilterNode> handler, final Class<T> clazz, final String column, final Serializable defValue, @RpcAttachment final FilterNode node) {
         Serializable rs = findColumn(clazz, column, defValue, node);
@@ -1747,6 +1948,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final Serializable pk) {
+        return CompletableFuture.supplyAsync(() -> exists(clazz, pk));
+    }
+
     @Override
     public <T> void existsAsync(final AsyncHandler<Boolean, Serializable> handler, final Class<T> clazz, @RpcAttachment final Serializable pk) {
         boolean rs = exists(clazz, pk);
@@ -1758,6 +1964,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return exists(clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> exists(clazz, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void existsAsync(final AsyncHandler<Boolean, B> handler, final Class<T> clazz, @RpcAttachment final B bean) {
         boolean rs = exists(clazz, bean);
@@ -1798,6 +2009,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         }
     }
 
+    @Override
+    public <T> CompletableFuture<Boolean> existsAsync(final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> exists(clazz, node));
+    }
+
     @Override
     public <T> void existsAsync(final AsyncHandler<Boolean, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         boolean rs = exists(clazz, node);
@@ -1806,10 +2022,15 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
 
     //-----------------------list set----------------------------
     @Override
-    public <T, V extends Serializable> HashSet<V> queryColumnSet(String selectedColumn, Class<T> clazz, String column, Serializable key) {
+    public <T, V extends Serializable> HashSet<V> queryColumnSet(final String selectedColumn, Class<T> clazz, String column, Serializable key) {
         return queryColumnSet(selectedColumn, clazz, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, Class<T> clazz, String column, Serializable key) {
+        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, column, key));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnSetAsync(final AsyncHandler<HashSet<V>, String> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final String column, final Serializable key) {
         HashSet<V> rs = queryColumnSet(selectedColumn, clazz, column, key);
@@ -1821,6 +2042,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return new LinkedHashSet<>(queryColumnList(selectedColumn, clazz, bean));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, bean));
+    }
+
     @Override
     public <T, V extends Serializable, B extends FilterBean> void queryColumnSetAsync(final AsyncHandler<HashSet<V>, B> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final B bean) {
         HashSet<V> rs = queryColumnSet(selectedColumn, clazz, bean);
@@ -1832,6 +2058,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return new LinkedHashSet<>(queryColumnList(selectedColumn, clazz, node));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<HashSet<V>> queryColumnSetAsync(final String selectedColumn, final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryColumnSet(selectedColumn, clazz, node));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnSetAsync(final AsyncHandler<HashSet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         HashSet<V> rs = queryColumnSet(selectedColumn, clazz, node);
@@ -1843,6 +2074,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnList(selectedColumn, clazz, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final String column, final Serializable key) {
+        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, column, key));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnListAsync(final AsyncHandler<List<V>, Serializable> handler, final String selectedColumn, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
         List<V> rs = queryColumnList(selectedColumn, clazz, column, key);
@@ -1854,6 +2090,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnList(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, bean));
+    }
+
     @Override
     public <T, V extends Serializable, B extends FilterBean> void queryColumnListAsync(final AsyncHandler<List<V>, B> handler, String selectedColumn, Class<T> clazz, @RpcAttachment B bean) {
         List<V> rs = queryColumnList(selectedColumn, clazz, bean);
@@ -1865,6 +2106,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return (List<V>) queryColumnSheet(false, selectedColumn, clazz, null, node).list(true);
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, node));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnListAsync(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         List<V> rs = queryColumnList(selectedColumn, clazz, node);
@@ -1876,6 +2122,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnList(selectedColumn, clazz, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, flipper, bean));
+    }
+
     @Override
     public <T, V extends Serializable, B extends FilterBean> void queryColumnListAsync(final AsyncHandler<List<V>, B> handler, String selectedColumn, Class<T> clazz, Flipper flipper, @RpcAttachment B bean) {
         List<V> rs = queryColumnList(selectedColumn, clazz, flipper, bean);
@@ -1887,6 +2138,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return (List<V>) queryColumnSheet(false, selectedColumn, clazz, flipper, node).list(true);
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<List<V>> queryColumnListAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryColumnList(selectedColumn, clazz, flipper, node));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnListAsync(final AsyncHandler<List<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, Flipper flipper, @RpcAttachment final FilterNode node) {
         List<V> rs = queryColumnList(selectedColumn, clazz, flipper, node);
@@ -1910,6 +2166,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnSheet(selectedColumn, clazz, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<Sheet<V>> queryColumnSheetAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryColumnSheet(selectedColumn, clazz, flipper, bean));
+    }
+
     @Override
     public <T, V extends Serializable, B extends FilterBean> void queryColumnSheetAsync(final AsyncHandler<Sheet<V>, B> handler, String selectedColumn, Class<T> clazz, Flipper flipper, @RpcAttachment B bean) {
         Sheet<V> rs = queryColumnSheet(selectedColumn, clazz, flipper, bean);
@@ -1921,6 +2182,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryColumnSheet(true, selectedColumn, clazz, flipper, node);
     }
 
+    @Override
+    public <T, V extends Serializable> CompletableFuture<Sheet<V>> queryColumnSheetAsync(final String selectedColumn, final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryColumnSheet(selectedColumn, clazz, flipper, node));
+    }
+
     @Override
     public <T, V extends Serializable> void queryColumnSheetAsync(final AsyncHandler<Sheet<V>, FilterNode> handler, final String selectedColumn, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
         Sheet<V> rs = queryColumnSheet(selectedColumn, clazz, flipper, node);
@@ -1957,6 +2223,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final String column, final Serializable key) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, column, key));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final String column, @RpcAttachment final Serializable key) {
         List<T> rs = queryList(clazz, column, key);
@@ -1977,6 +2248,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, (SelectColumn) null, bean);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void queryListAsync(final AsyncHandler<List<T>, B> handler, final Class<T> clazz, @RpcAttachment final B bean) {
         List<T> rs = queryList(clazz, bean);
@@ -1988,6 +2264,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, (SelectColumn) null, node);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, node));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, @RpcAttachment final FilterNode node) {
         List<T> rs = queryList(clazz, node);
@@ -2009,6 +2290,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, selects, (Flipper) null, bean);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, SelectColumn selects, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void queryListAsync(final AsyncHandler<List<T>, B> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final B bean) {
         List<T> rs = queryList(clazz, selects, bean);
@@ -2020,6 +2306,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, selects, (Flipper) null, node);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, SelectColumn selects, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, node));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, @RpcAttachment final FilterNode node) {
         List<T> rs = queryList(clazz, selects, node);
@@ -2031,6 +2322,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, flipper, FilterNode.create(column, key));
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final String column, final Serializable key) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, column, key));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, Serializable> handler, final Class<T> clazz, final Flipper flipper, final String column, @RpcAttachment final Serializable key) {
         List<T> rs = queryList(clazz, flipper, column, key);
@@ -2042,6 +2338,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, null, flipper, bean);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void queryListAsync(final AsyncHandler<List<T>, B> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final B bean) {
         List<T> rs = queryList(clazz, flipper, bean);
@@ -2053,6 +2354,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return queryList(clazz, null, flipper, node);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, flipper, node));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
         List<T> rs = queryList(clazz, flipper, node);
@@ -2064,6 +2370,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(true, false, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean)).list(true);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, flipper, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void queryListAsync(final AsyncHandler<List<T>, B> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) {
         List<T> rs = queryList(clazz, selects, flipper, bean);
@@ -2075,6 +2386,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(true, false, clazz, selects, flipper, node).list(true);
     }
 
+    @Override
+    public <T> CompletableFuture<List<T>> queryListAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> queryList(clazz, selects, flipper, node));
+    }
+
     @Override
     public <T> void queryListAsync(final AsyncHandler<List<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) {
         List<T> rs = queryList(clazz, selects, flipper, node);
@@ -2097,6 +2413,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(clazz, null, flipper, bean);
     }
 
+    @Override
+    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> querySheet(clazz, flipper, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void querySheetAsync(final AsyncHandler<Sheet<T>, B> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final B bean) {
         Sheet<T> rs = querySheet(clazz, flipper, bean);
@@ -2108,6 +2429,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(clazz, null, flipper, node);
     }
 
+    @Override
+    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> querySheet(clazz, flipper, node));
+    }
+
     @Override
     public <T> void querySheetAsync(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final Flipper flipper, @RpcAttachment final FilterNode node) {
         Sheet<T> rs = querySheet(clazz, flipper, node);
@@ -2130,6 +2456,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(true, true, clazz, selects, flipper, FilterNodeBean.createFilterNode(bean));
     }
 
+    @Override
+    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterBean bean) {
+        return CompletableFuture.supplyAsync(() -> querySheet(clazz, selects, flipper, bean));
+    }
+
     @Override
     public <T, B extends FilterBean> void querySheetAsync(final AsyncHandler<Sheet<T>, B> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final B bean) {
         Sheet<T> rs = querySheet(clazz, selects, flipper, bean);
@@ -2141,6 +2472,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, Servi
         return querySheet(true, true, clazz, selects, flipper, node);
     }
 
+    @Override
+    public <T> CompletableFuture<Sheet<T>> querySheetAsync(final Class<T> clazz, final SelectColumn selects, final Flipper flipper, final FilterNode node) {
+        return CompletableFuture.supplyAsync(() -> querySheet(clazz, selects, flipper, node));
+    }
+
     @Override
     public <T> void querySheetAsync(final AsyncHandler<Sheet<T>, FilterNode> handler, final Class<T> clazz, final SelectColumn selects, final Flipper flipper, @RpcAttachment final FilterNode node) {
         Sheet<T> rs = querySheet(clazz, selects, flipper, node);