support async execute api.

cola-components/cola-component-extension-starter/src/main/java/com/alibaba/cola/extension/register/AbstractComponentExecutor.java

@@ -3,6 +3,10 @@
 import com.alibaba.cola.extension.BizScenario;
 import com.alibaba.cola.extension.ExtensionCoordinate;
 
+import java.util.Objects;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Consumer;
 import java.util.function.Function;
 
@@ -31,6 +35,26 @@ public <R, T> R execute(ExtensionCoordinate extensionCoordinate, Function<T, R>
         return execute((Class<T>) extensionCoordinate.getExtensionPointClass(), extensionCoordinate.getBizScenario(), exeFunction);
     }
 
+    public <R, T> CompletableFuture<R> executeAsync(Class<T> targetClz, BizScenario bizScenario, Function<T, R> exeFunction) {
+        return executeAsync(targetClz, bizScenario, exeFunction, null);
+    }
+
+    /**
+     * the async execute api. if the param {executor} is null, will use forkJoin pool
+     * other similar.
+     */
+    public <R, T> CompletableFuture<R> executeAsync(Class<T> targetClz, BizScenario bizScenario, Function<T, R> exeFunction, Executor executor) {
+        return CompletableFuture.supplyAsync(() -> execute(targetClz, bizScenario, exeFunction), Objects.nonNull(executor) ? executor : ForkJoinPool.commonPool());
+    }
+
+    public <R, T> CompletableFuture<R> executeAsync(ExtensionCoordinate extensionCoordinate, Function<T, R> exeFunction) {
+        return executeAsync(extensionCoordinate, exeFunction, null);
+    }
+
+    public <R, T> CompletableFuture<R> executeAsync(ExtensionCoordinate extensionCoordinate, Function<T, R> exeFunction, Executor executor) {
+        return CompletableFuture.supplyAsync(() -> execute(extensionCoordinate, exeFunction), Objects.nonNull(executor) ? executor : ForkJoinPool.commonPool());
+    }
+
     /**
      * Execute extension without Response
      *
@@ -48,5 +72,21 @@ public <T> void executeVoid(ExtensionCoordinate extensionCoordinate, Consumer<T>
         executeVoid(extensionCoordinate.getExtensionPointClass(), extensionCoordinate.getBizScenario(), exeFunction);
     }
 
+    public <T> void executeVoidAsync(Class<T> targetClz, BizScenario context, Consumer<T> exeFunction) {
+        executeVoidAsync(targetClz, context, exeFunction, null);
+    }
+
+    public <T> void executeVoidAsync(Class<T> targetClz, BizScenario context, Consumer<T> exeFunction, Executor executor) {
+        CompletableFuture.runAsync(() -> executeVoid(targetClz, context, exeFunction), Objects.nonNull(executor) ? executor : ForkJoinPool.commonPool());
+    }
+
+    public <T> void executeVoidAsync(ExtensionCoordinate extensionCoordinate, Consumer<T> exeFunction) {
+        executeVoidAsync(extensionCoordinate, exeFunction, null);
+    }
+
+    public <T> void executeVoidAsync(ExtensionCoordinate extensionCoordinate, Consumer<T> exeFunction, Executor executor) {
+        CompletableFuture.runAsync(() -> executeVoid(extensionCoordinate, exeFunction), Objects.nonNull(executor) ? executor : ForkJoinPool.commonPool());
+    }
+
     protected abstract <C> C locateComponent(Class<C> targetClz, BizScenario context);
 }

cola-components/cola-component-statemachine/pom.xml

@@ -8,6 +8,7 @@
     </parent>
 
     <artifactId>cola-component-statemachine</artifactId>
+    <version>4.4.1-SNAPSHOT</version>
     <packaging>jar</packaging>
     <name>${project.artifactId}</name>
     <description>${project.artifactId}</description>