Add asynchronous processing methods in PythonProcessor and update dependencies.

Author: maksymuimanov

common/python-executor-common/src/main/java/io/maksymuimanov/python/executor/InterpretablePythonExecutor.java

@@ -16,7 +16,7 @@ protected InterpretablePythonExecutor(PythonInterpreterFactory<I> interpreterFac
 
     public <R> PythonExecutionResponse<R> execute(PythonScript script, @Nullable Class<? extends R> resultClass) {
         try (I interpreter = interpreterFactory.create()) {
-            return execute(script, resultClass, interpreter);
+            return this.execute(script, resultClass, interpreter);
         } catch (Exception e) {
             throw new PythonExecutionException(e);
         }

common/python-executor-common/src/main/java/io/maksymuimanov/python/processor/PythonProcessor.java

@@ -8,6 +8,9 @@
 import org.jspecify.annotations.Nullable;
 
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ForkJoinPool;
 
 /**
  * Defines the contract for processing and executing Python scripts, acting as a bridge between
@@ -32,12 +35,77 @@
  * @since 1.0.0
  */
 public interface PythonProcessor {
+    default CompletableFuture<Void> processAsync(String script) {
+        return this.processAsync(script, Map.of());
+    }
+
+    default CompletableFuture<Void> processAsync(PythonScript script) {
+        return this.processAsync(script, Map.of());
+    }
+
+    default CompletableFuture<Void> processAsync(String script, Map<String, Object> arguments) {
+        return this.processAsync(script, arguments, ForkJoinPool.commonPool());
+    }
+
+    default CompletableFuture<Void> processAsync(PythonScript script, Map<String, Object> arguments) {
+        return this.processAsync(script, arguments, ForkJoinPool.commonPool());
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(String script, @Nullable Class<? extends R> resultClass) {
+        return this.processAsync(script, resultClass, Map.of());
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(PythonScript script, @Nullable Class<? extends R> resultClass) {
+        return this.processAsync(script, resultClass, Map.of());
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(String script, @Nullable Class<? extends R> resultClass, Map<String, Object> arguments) {
+        return this.processAsync(script, resultClass, arguments, ForkJoinPool.commonPool());
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(PythonScript script, @Nullable Class<? extends R> resultClass, Map<String, Object> arguments) {
+        return this.processAsync(script, resultClass, arguments, ForkJoinPool.commonPool());
+    }
+
+    default CompletableFuture<Void> processAsync(String script, Executor executor) {
+        return this.processAsync(script, Map.of(), executor);
+    }
+
+    default CompletableFuture<Void> processAsync(PythonScript script, Executor executor) {
+        return this.processAsync(script, Map.of(), executor);
+    }
+
+    default CompletableFuture<Void> processAsync(String script, Map<String, Object> arguments, Executor executor) {
+        return CompletableFuture.runAsync(() -> this.process(script, arguments), executor);
+    }
+
+    default CompletableFuture<Void> processAsync(PythonScript script, Map<String, Object> arguments, Executor executor) {
+        return CompletableFuture.runAsync(() -> this.process(script, arguments), executor);
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(String script, @Nullable Class<? extends R> resultClass, Executor executor) {
+        return this.processAsync(script, resultClass, Map.of(), executor);
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(PythonScript script, @Nullable Class<? extends R> resultClass, Executor executor) {
+        return this.processAsync(script, resultClass, Map.of(), executor);
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(String script, @Nullable Class<? extends R> resultClass, Map<String, Object> arguments, Executor executor) {
+        PythonScript pythonScript = new PythonScript(script);
+        return this.processAsync(pythonScript, resultClass, arguments, executor);
+    }
+
+    default <R> CompletableFuture<PythonExecutionResponse<R>> processAsync(PythonScript script, @Nullable Class<? extends R> resultClass, Map<String, Object> arguments, Executor executor) {
+        return CompletableFuture.supplyAsync(() -> this.process(script, resultClass, arguments), executor);
+    }
+
     /**
      * Processes and executes a Python script without additional arguments or body mapping.
      *
      * @param script non-{@code null} Python script to execute
      */
-    default PythonExecutionResponse<?> process(String script) {
+    default PythonExecutionResponse<Void> process(String script) {
         return this.process(script, null, Map.of());
     }
 
@@ -46,7 +114,7 @@ default PythonExecutionResponse<?> process(String script) {
      *
      * @param script non-{@code null} Python script to execute
      */
-    default PythonExecutionResponse<?> process(PythonScript script) {
+    default PythonExecutionResponse<Void> process(PythonScript script) {
         return this.process(script, null, Map.of());
     }
 
@@ -56,7 +124,7 @@ default PythonExecutionResponse<?> process(PythonScript script) {
      * @param script non-{@code null} Python script to execute
      * @param arguments a map of arguments accessible to resolvers during preprocessing
      */
-    default PythonExecutionResponse<?> process(String script, Map<String, Object> arguments) {
+    default PythonExecutionResponse<Void> process(String script, Map<String, Object> arguments) {
         return this.process(script, null, arguments);
     }
 
@@ -66,7 +134,7 @@ default PythonExecutionResponse<?> process(String script, Map<String, Object> ar
      * @param script non-{@code null} Python script to execute
      * @param arguments a map of arguments accessible to resolvers during preprocessing
      */
-    default PythonExecutionResponse<?> process(PythonScript script, Map<String, Object> arguments) {
+    default PythonExecutionResponse<Void> process(PythonScript script, Map<String, Object> arguments) {
         return this.process(script, null, arguments);
     }
 

core/python-executor-spring-boot-starter/pom.xml

@@ -53,7 +53,7 @@
         </dependency>
         <dependency>
             <groupId>io.github.maksymuimanov</groupId>
-            <artifactId>python-executor-jep-executor-spring-boot-starter</artifactId>
+            <artifactId>python-executor-graalpy-executor-spring-boot-starter</artifactId>
             <version>${project.version}</version>
         </dependency>
         <dependency>