39 |
|
System.out.printf("seq : %9.5f\n", elapsed); |
40 |
|
} |
41 |
|
|
42 |
– |
ForkJoinPool fjp = new ForkJoinPool(2); |
42 |
|
for (int sweeps = 0; sweeps < 2; ++sweeps) { |
43 |
|
for (int i = 2; i <= NCPU; i <<= 1) { |
44 |
< |
fjp.setParallelism(i); |
44 |
> |
ForkJoinPool fjp = new ForkJoinPool(i); |
45 |
|
oneRun(fjp, array, i, reps, tests); |
46 |
+ |
fjp.shutdown(); |
47 |
|
} |
48 |
|
for (int i = NCPU; i >= 1; i >>>= 1) { |
49 |
< |
fjp.setParallelism(i); |
49 |
> |
ForkJoinPool fjp = new ForkJoinPool(i); |
50 |
|
oneRun(fjp, array, i, reps, tests); |
51 |
+ |
fjp.shutdown(); |
52 |
|
} |
53 |
|
} |
53 |
– |
fjp.shutdown(); |
54 |
|
} |
55 |
|
|
56 |
|
static void oneRun(ForkJoinPool fjp, |