--- jsr166/src/test/loops/Integrate.java	2009/10/29 23:09:07	1.2
+++ jsr166/src/test/loops/Integrate.java	2010/11/29 20:58:06	1.12
@@ -4,7 +4,6 @@
  * http://creativecommons.org/licenses/publicdomain
  */
 
-//import jsr166y.*;
 import java.util.concurrent.*;
 
 /**
@@ -27,7 +26,7 @@ public final class Integrate {
     static String forkArg = "dynamic";
 
     // the function to integrate
-    static double computeFunction(double x)  {
+    static double computeFunction(double x) {
         return (x * x + 1.0) * x;
     }
 
@@ -41,7 +40,7 @@ public final class Integrate {
     static final int calls = 263479047;
 
     public static void main(String[] args) throws Exception {
-        int procs = Runtime.getRuntime().availableProcessors();
+        int procs = 0;
 
         try {
             if (args.length > 0)
@@ -58,12 +57,19 @@ public final class Integrate {
             System.out.println("Usage: java Integrate3 threads <s[erial] | d[ynamic] | f[ork] - default d>");
             return;
         }
+        oneTest(procs);
+        oneTest(procs);
+        oneTest(procs);
+    }
 
-        ForkJoinPool g = new ForkJoinPool(procs);
+    static void oneTest(int procs) {
+        ForkJoinPool g = (procs == 0) ? new ForkJoinPool() :
+            new ForkJoinPool(procs);
+        System.out.println("Number of procs=" + g.getParallelism());
         System.out.println("Integrating from " + start + " to " + end +
                            " forkPolicy = " + forkArg);
         long lastTime = System.nanoTime();
-        for (int i = 0; i < 10; ++i) {
+        for (int i = 0; i < 20; ++i) {
             double a;
             if (forkPolicy == SERIAL)
                 a = SQuad.computeArea(g, start, end);
@@ -76,7 +82,8 @@ public final class Integrate {
             lastTime = now;
             System.out.printf("Calls/sec: %12d", (long) (calls / s));
             System.out.printf(" Time: %7.3f", s);
-            System.out.printf(" Area: %12.1f", a);
+            System.out.printf(" Threads: %5d", g.getPoolSize());
+            //            System.out.printf(" Area: %12.1f", a);
             System.out.println();
         }
         System.out.println(g);
@@ -162,7 +169,7 @@ public final class Integrate {
             q.fork();
             ar = recEval(c, r, fc, fr, ar);
             if (!q.tryUnfork()) {
-                q.quietlyHelpJoin();
+                q.quietlyJoin();
                 return ar + q.area;
             }
             return ar + recEval(l, c, fl, fc, al);
@@ -210,7 +217,7 @@ public final class Integrate {
                 (q = new DQuad(l, c, al)).fork();
             ar = recEval(c, r, fc, fr, ar);
             if (q != null && !q.tryUnfork()) {
-                q.quietlyHelpJoin();
+                q.quietlyJoin();
                 return ar + q.area;
             }
             return ar + recEval(l, c, fl, fc, al);
@@ -219,3 +226,5 @@ public final class Integrate {
     }
 
 }
+
+