new Constants

Author: codetojoy

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

@@ -0,0 +1,9 @@
+
+package net.codetojoy;
+
+class Constants {
+    static final int NUM_TASKS = 20;
+    static final int NUM_TASKS_FOR_SUCCESS = 5;
+    static final int MAX_DELAY_IN_SECONDS = 6;
+    static final int PATHOGEN_THRESHOLD = 3; // 30% chance of failure
+}

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

@@ -2,15 +2,14 @@
 // note: I no longer own this domain
 package net.codetojoy;
 
+import static net.codetojoy.Constants.*;
+
 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
-
 public class Runner {
     private final Random random = new Random(System.currentTimeMillis());
-    private static final int MAX_DELAY_IN_SECONDS = 6;
 
     String taskFoo(int i) {
         long delayInMillis = (random.nextInt(MAX_DELAY_IN_SECONDS) + 1) * 1000L;
@@ -23,11 +22,9 @@ String taskFoo(int i) {
     }
 
     List<String> run() throws Exception {
-        int numTasksForSuccess = 5;
-        StructuredTaskScope.Joiner<String,List<String>> joiner = new CustomJoiner(numTasksForSuccess);
+        StructuredTaskScope.Joiner<String,List<String>> joiner = new CustomJoiner(NUM_TASKS_FOR_SUCCESS);
         try (var scope = StructuredTaskScope.open(joiner)) {
-            int numTasks = 50;
-            IntStream.range(0, numTasks).forEach(i -> scope.fork(() -> taskFoo(i))); 
+            IntStream.range(0, NUM_TASKS).forEach(i -> scope.fork(() -> taskFoo(i))); 
 
             return scope.join();
         }

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

@@ -2,10 +2,11 @@
 // note:  I no longer own this domain
 package net.codetojoy;
 
+import static net.codetojoy.Constants.*;
+
 import java.time.Duration;
 
 class Worker { 
-    public static final int pathogenThreshold = 3;
     public static final long THROW_EXCEPTION = -1L;
     public static final String LOG_PREFIX = "TRACER Worker: ";
 
@@ -28,7 +29,7 @@ boolean isPathogenic() {
         int min = 1;
         int max = 10;
         int randomNum = min + (int)(Math.random() * ((max - min) + 1));
-        return randomNum < pathogenThreshold;
+        return randomNum < PATHOGEN_THRESHOLD;
     }
 
     // see https://stackoverflow.com/questions/15160782