26 |
|
static String forkArg = "dynamic"; |
27 |
|
|
28 |
|
// the function to integrate |
29 |
< |
static double computeFunction(double x) { |
29 |
> |
static double computeFunction(double x) { |
30 |
|
return (x * x + 1.0) * x; |
31 |
|
} |
32 |
|
|
63 |
|
} |
64 |
|
|
65 |
|
static void oneTest(int procs) { |
66 |
< |
ForkJoinPool g = procs == 0? new ForkJoinPool() : |
66 |
> |
ForkJoinPool g = (procs == 0) ? new ForkJoinPool() : |
67 |
|
new ForkJoinPool(procs); |
68 |
|
System.out.println("Number of procs=" + g.getParallelism()); |
69 |
|
System.out.println("Integrating from " + start + " to " + end + |
169 |
|
q.fork(); |
170 |
|
ar = recEval(c, r, fc, fr, ar); |
171 |
|
if (!q.tryUnfork()) { |
172 |
– |
// q.quietlyHelpJoin(); |
172 |
|
q.quietlyJoin(); |
173 |
|
return ar + q.area; |
174 |
|
} |
217 |
|
(q = new DQuad(l, c, al)).fork(); |
218 |
|
ar = recEval(c, r, fc, fr, ar); |
219 |
|
if (q != null && !q.tryUnfork()) { |
221 |
– |
// q.quietlyHelpJoin(); |
220 |
|
q.quietlyJoin(); |
221 |
|
return ar + q.area; |
222 |
|
} |