#11 - add to hierarchy

org.obrienscience.concurrent.CollatzBeowulfSE/src/main/java/org/obrienscience/collatz/server/ForkJoinCollatzServer.java

@@ -4,7 +4,7 @@
 import java.util.concurrent.ForkJoinPool;
 
 public class ForkJoinCollatzServer {
-    private ForkJoinPool mapReducePool;
+    protected ForkJoinPool mapReducePool;
 
 	public void compute(long pool, long threads, long uowSplit, long extent) {
 		BigInteger maxPath = BigInteger.ONE;

org.obrienscience.concurrent.CollatzBeowulfSE/src/main/java/org/obrienscience/collatz/server/ForkJoinCollatzServerStatic8.java

@@ -0,0 +1,64 @@
+package org.obrienscience.collatz.server;
+
+import java.math.BigInteger;
+import java.util.concurrent.ForkJoinPool;
+
+/**
+ * @author [email protected]
+ */
+public class ForkJoinCollatzServerStatic8 extends ForkJoinCollatzServer {
+
+	@Override
+	public void compute(long pool, long threads, long uowSplit, long extent) {
+		BigInteger maxPath = BigInteger.ONE;
+		BigInteger maxValue = BigInteger.ONE;
+		ForkJoinUnitOfWork forkJoinUOW = new ForkJoinUnitOfWork(uowSplit, 0, extent, maxPath, maxValue);
+		long startTime = System.currentTimeMillis();
+		// create a pool of threads to the power of pool * # of (proc + ht)
+		mapReducePool = new ForkJoinPool(1 << pool);//Runtime.getRuntime().availableProcessors() << pool);
+		mapReducePool.invoke(forkJoinUOW);
+		long endTime = System.currentTimeMillis();
+		System.out.println(new StringBuffer(
+				String.valueOf(endTime - startTime)).append(",")
+				.append(pool).append(",")
+				.append(threads).append(",")
+				.append(String.valueOf((endTime - startTime) / 1000))
+				.append(threads).append(",").append(uowSplit).toString());
+	}
+
+	public static void main(String[] args) {
+	    System.out.println("ForkJoinUnitOfWork8 (v 20240101)");
+		long poolStart = 1;
+		long poolEnd = 1;
+		long runs = 1;
+		/*
+	    if(null != args && args.length > 0) {
+        	poolStart = Long.parseLong(args[0]);
+        }   
+	    if(null != args && args.length > 1) {
+        	poolEnd = Long.parseLong(args[1]);
+        }   
+	    if(null != args && args.length > 2) {
+        	runs = Long.parseLong(args[2]);
+        } */
+		System.out.println("availableProc\t: " + Runtime.getRuntime().availableProcessors());
+		//System.out.println("fjps threads\t: " + poolStart + "," + poolEnd);
+		System.out.println("freeMemory()\t: " + Runtime.getRuntime().freeMemory());
+		System.out.println("maxMemory()\t: " + Runtime.getRuntime().maxMemory());
+		System.out.println("totalMemory()\t: " + Runtime.getRuntime().totalMemory());
+		System.out.println("System.getEnv()\t: " + System.getenv().toString());
+		ForkJoinCollatzServerStatic8 server = new ForkJoinCollatzServerStatic8();
+		long extent = 4;//25;
+
+
+		System.out.println("Range: bits\t: " + extent);
+		//for(long r=0;r<runs;r++) {
+			//for(long p=poolStart;p<poolEnd + 1;p++) {
+				//for(long i=3;i<extent + 1;i++) {
+					server.compute(3, 3, 3, 3);//poolStart, extent - i, 1 << i, 1 << extent);
+
+				//}
+			//}
+		//}
+	}
+}

org.obrienscience.concurrent.CollatzBeowulfSE/src/main/java/org/obrienscience/collatz/server/ForkJoinUnitOfWork.java

@@ -14,13 +14,13 @@ public class ForkJoinUnitOfWork extends RecursiveAction {
 	private static final long serialVersionUID = 2854227036188716499L;
     public static final BigInteger COLLATZ88 = BigInteger.valueOf(1980976057694848447L);     
     public static final BigInteger COLLATZ_2651 = new  BigInteger("2367363789863971985761"); // path of 2651
-    private static final BigInteger BIG_INTEGER_TWO = BigInteger.valueOf(2);
+    protected static final BigInteger BIG_INTEGER_TWO = BigInteger.valueOf(2);
 
-	private long start;
-	private long len;
-	private long uowSplit = 1024;
-	private BigInteger maximumPath;
-	private BigInteger maximumValue;
+	protected long start;
+	protected long len;
+	protected long uowSplit = 1024;
+	protected BigInteger maximumPath;
+	protected BigInteger maximumValue;
 
 	public ForkJoinUnitOfWork(long split, long start, long len, BigInteger maxPath, BigInteger maxValue) {
 		this.uowSplit = split;