egg8 jdk 25

Author: codetojoy

egg_8_sc_custom_invoke_some/compile.sh

@@ -10,7 +10,7 @@ TARGET_DIR=$ROOT_DIR/my_build/main
 
 mkdir -p $TARGET_DIR
 
-javac --release 21 --enable-preview \
+javac --release 25 --enable-preview \
 -cp $CLASSPATH \
 -d $TARGET_DIR `find $SRC_DIR -name "*.java"`
 

egg_8_sc_custom_invoke_some/run.sh

@@ -9,7 +9,6 @@ CLASSPATH=$CLASSPATH:$TARGET_DIR
 
 java --enable-preview \
 -cp $CLASSPATH \
---add-modules jdk.incubator.concurrent \
 net.codetojoy.Runner
 
 echo "run complete"

…codetojoy/CustomStructuredTaskScope.java …ain/java/net/codetojoy/CustomJoiner.javaegg_8_sc_custom_invoke_some/src/main/java/net/codetojoy/CustomStructuredTaskScope.java renamed to egg_8_sc_custom_invoke_some/src/main/java/net/codetojoy/CustomJoiner.java egg_8_sc_custom_invoke_some/src/main/java/net/codetojoy/CustomStructuredTaskScope.java renamed to egg_8_sc_custom_invoke_some/src/main/java/net/codetojoy/CustomJoiner.java

@@ -5,15 +5,16 @@
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.*;
+import java.util.concurrent.StructuredTaskScope.Joiner;
 
 // NOTE: this is NOT production-ready, just an experiment
 // 
-// this is similar in spirit to StructuredTaskScope.ShutdownOnSuccess<T>, but for N tasks
+// this is similar in spirit to ShutdownOnSuccess<T>, but for N tasks
 // i.e. given M tasks, success is defined when N of them complete successfully
 // to wit: `invokeSome(n)`
 
-public class CustomStructuredTaskScope<T> extends StructuredTaskScope<T> {
-    private static final String LOG_PREFIX = "TRACER CustomStructuredTaskScope ";
+public class CustomJoiner<T> implements Joiner<T,List<T>> {
+    private static final String LOG_PREFIX = "TRACER CustomJoiner ";
 
     private AtomicInteger successCounter = new AtomicInteger(0);
     private AtomicBoolean hasReachedThreshold = new AtomicBoolean(false);
@@ -23,10 +24,50 @@ public class CustomStructuredTaskScope<T> extends StructuredTaskScope<T> {
     // sanity check:
     private AtomicInteger failCounter = new AtomicInteger(0);
 
-    public CustomStructuredTaskScope(int numTasksForSuccess) {
+    public CustomJoiner(int numTasksForSuccess) {
         this.numTasksForSuccess = numTasksForSuccess;
     } 
 
+    @Override
+    public boolean onComplete(StructuredTaskScope.Subtask<? extends T> subtask) {
+        boolean result = false;
+
+        try { 
+            var state = subtask.state();
+            if (state == StructuredTaskScope.Subtask.State.SUCCESS) {
+                int numSuccess = successCounter.incrementAndGet();
+                if (numSuccess <= numTasksForSuccess) {
+                    results.add(subtask.get());
+                } 
+
+                if (numSuccess == numTasksForSuccess) {
+                    hasReachedThreshold.getAndSet(true);
+                    System.out.println(LOG_PREFIX + " success threshold reached...");
+                    result = true;
+                }
+            } else if (state == StructuredTaskScope.Subtask.State.FAILED) {
+                failCounter.incrementAndGet();
+            }
+        } catch (Exception ex) {
+            System.err.println(LOG_PREFIX + " ERROR caught ex: " + ex.getMessage());
+        }
+
+        return result;
+    }
+
+    @Override
+    public List<T> result() {
+        if (! hasReachedThreshold.get()) {
+            throw new IllegalStateException("success threshold not met");
+        } 
+        System.out.println(LOG_PREFIX + " success! num ok: " + numTasksForSuccess +
+                            " num failed: " + failCounter.get());
+
+        return results;
+    }
+
+    /*
+     * 
     @Override
     protected void handleComplete(StructuredTaskScope.Subtask<? extends T> subtask) {
         try { 
@@ -60,4 +101,5 @@ public List<T> results() {
 
         return new ArrayList<T>(results);
     }
+     */
 }

egg_8_sc_custom_invoke_some/src/main/java/net/codetojoy/Runner.java

@@ -4,6 +4,7 @@
 
 import java.util.*;
 import java.util.stream.IntStream;
+import java.util.concurrent.*;
 
 // javadoc here: https://download.java.net/java/early_access/jdk19/docs/api/jdk.incubator.concurrent/jdk/incubator/concurrent/package-summary.html
 
@@ -23,13 +24,12 @@ String taskFoo(int i) {
 
     List<String> run() throws Exception {
         int numTasksForSuccess = 5;
-        try (var scope = new CustomStructuredTaskScope<String>(numTasksForSuccess)) {
+        StructuredTaskScope.Joiner<String,List<String>> joiner = new CustomJoiner(numTasksForSuccess);
+        try (var scope = StructuredTaskScope.open(joiner)) {
             int numTasks = 50;
             IntStream.range(0, numTasks).forEach(i -> scope.fork(() -> taskFoo(i))); 
 
-            scope.join();
-
-            return scope.results();
+            return scope.join();
         }
     }