Executor module (#876)

Author: gthea

build.gradle

@@ -145,7 +145,7 @@ dependencies {
         return candidates.find { findProject(it) != null }
     }
 
-    ['main', 'logger', 'events', 'events-domain', 'api', 'http-api', 'http', 'fallback', 'backoff', 'tracker', 'submitter'].each { moduleName ->
+    ['main', 'logger', 'executor', 'events', 'events-domain', 'api', 'http-api', 'http', 'fallback', 'backoff', 'tracker', 'submitter'].each { moduleName ->
         def resolvedPath = resolveProjectPath(moduleName)
         if (resolvedPath != null) {
             include project(resolvedPath)

events-domain/build.gradle

@@ -16,6 +16,7 @@ android {
 dependencies {
     implementation libs.annotation
 
+    api clientModuleProject('executor')
     implementation clientModuleProject('api')
     implementation clientModuleProject('events')
     implementation clientModuleProject('logger')

events-domain/src/main/java/io/split/android/client/service/executor/SplitTaskType.java

@@ -0,0 +1,5 @@
+/build
+.gradle
+local.properties
+.classpath
+.settings

executor/.gitignore

@@ -0,0 +1,60 @@
+# executor
+
+Generic task scheduling and execution infrastructure for the Split Android SDK.
+
+## Purpose
+
+Provides a pausable task executor with support for scheduled and immediate task execution, parallel task execution with timeout, serial and batch task wrappers, main thread task execution via Android Handler, and pause/resume/stop controls.
+
+## Usage
+
+### Basic Task Execution
+
+```java
+SplitTaskExecutor executor = new SplitTaskExecutorImpl();
+
+SplitTask task = () -> {
+    // Do work
+    return SplitTaskExecutionInfo.success(SplitTaskType.GENERIC_TASK);
+};
+
+executor.submit(task, null);
+```
+
+### Scheduled Execution
+
+```java
+executor.schedule(
+    task,
+    60,  // delay in seconds
+    null  // optional listener
+);
+```
+
+### Parallel Execution
+
+```java
+SplitParallelTaskExecutor<Result> parallelExecutor =
+    new SplitParallelTaskExecutorFactoryImpl().build();
+
+List<Callable<Result>> tasks = Arrays.asList(
+    () -> fetchData1(),
+    () -> fetchData2()
+);
+
+List<Result> results = parallelExecutor.executeParallelTasks(tasks, 60);
+```
+
+### Lifecycle Management
+
+```java
+executor.pause();   // Pause scheduled tasks
+executor.resume();  // Resume scheduled tasks
+executor.stop();    // Stop and shutdown executor
+```
+
+## Dependencies
+
+- **logger**: Logging abstraction
+- **Android framework**: Handler/Looper for main thread execution
+- **AndroidX annotations**: @NonNull, @Nullable, etc.

executor/README.md

@@ -0,0 +1,22 @@
+plugins {
+    id 'com.android.library'
+}
+
+apply from: "$projectDir/../gradle/common-android-library.gradle"
+
+android {
+    namespace 'io.split.android.client.executor'
+
+    compileOptions {
+        sourceCompatibility JavaVersion.VERSION_1_8
+        targetCompatibility JavaVersion.VERSION_1_8
+    }
+}
+
+dependencies {
+    implementation libs.annotation
+    implementation clientModuleProject('logger')
+
+    testImplementation libs.junit4
+    testImplementation libs.mockitoCore
+}

executor/build.gradle

@@ -1,8 +1,5 @@
 package io.split.android.client.service.executor;
 
-import static io.split.android.client.utils.Utils.checkArgument;
-import static io.split.android.client.utils.Utils.checkNotNull;
-
 import android.os.Handler;
 import android.os.Looper;
 
@@ -12,6 +9,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ScheduledFuture;
@@ -42,8 +40,10 @@ public String schedule(@NonNull SplitTask task,
                            long periodInSecs,
                            @Nullable SplitTaskExecutionListener executionListener
     ) {
-        checkNotNull(task);
-        checkArgument(periodInSecs > 0);
+        Objects.requireNonNull(task);
+        if (periodInSecs <= 0) {
+            throw new IllegalArgumentException("periodInSecs must be positive");
+        }
 
         String taskId = null;
         if (!mScheduler.isShutdown()) {
@@ -62,7 +62,7 @@ public String schedule(@NonNull SplitTask task,
                            long initialDelayInSecs,
                            @Nullable SplitTaskExecutionListener executionListener
     ) {
-        checkNotNull(task);
+        Objects.requireNonNull(task);
         String taskId = null;
         if (!mScheduler.isShutdown()) {
             ScheduledFuture<?> taskFuture = mScheduler.schedule(
@@ -77,7 +77,7 @@ public String schedule(@NonNull SplitTask task,
     @Override
     public void submit(@NonNull SplitTask task,
                        @Nullable SplitTaskExecutionListener executionListener) {
-        checkNotNull(task);
+        Objects.requireNonNull(task);
         if (!mScheduler.isShutdown()) {
             mScheduler.submit(new TaskWrapper(task, executionListener));
         }