| 1 |
|
/* |
| 2 |
|
* Written by Doug Lea with assistance from members of JCP JSR-166 |
| 3 |
|
* Expert Group and released to the public domain, as explained at |
| 4 |
< |
* http://creativecommons.org/licenses/publicdomain |
| 4 |
> |
* http://creativecommons.org/publicdomain/zero/1.0/ |
| 5 |
|
*/ |
| 6 |
|
import java.util.concurrent.*; |
| 7 |
|
|
| 32 |
|
Thread.sleep(100); |
| 33 |
|
} |
| 34 |
|
pool.shutdown(); |
| 35 |
< |
} |
| 35 |
> |
} |
| 36 |
|
|
| 37 |
|
static void oneRun(BlockingQueue<Integer> q, int npairs, int iters) throws Exception { |
| 38 |
|
LoopHelpers.BarrierTimer timer = new LoopHelpers.BarrierTimer(); |
| 39 |
|
CyclicBarrier barrier = new CyclicBarrier(npairs * 2 + 1, timer); |
| 40 |
< |
Future[] prods = new Future[npairs]; |
| 41 |
< |
Future[] cons = new Future[npairs]; |
| 40 |
> |
Future<?>[] prods = new Future<?>[npairs]; |
| 41 |
> |
Future<?>[] cons = new Future<?>[npairs]; |
| 42 |
|
|
| 43 |
|
for (int i = 0; i < npairs; ++i) { |
| 44 |
|
prods[i] = pool.submit(new Producer(q, barrier, iters)); |
