# | Line 6 | Line 6 | |
---|---|---|
6 | ||
7 | import java.util.concurrent.*; | |
8 | ||
9 | – | |
9 | public class TimeoutProducerConsumerLoops { | |
10 | static final int NCPUS = Runtime.getRuntime().availableProcessors(); | |
11 | static final ExecutorService pool = Executors.newCachedThreadPool(); | |
# | Line 51 | Line 50 | public class TimeoutProducerConsumerLoop | |
50 | maxPairs = Integer.parseInt(args[0]); | |
51 | ||
52 | print = true; | |
53 | < | int k = 1; |
55 | < | for (int i = 1; i <= maxPairs;) { |
53 | > | for (int k = 1, i = 1; i <= maxPairs;) { |
54 | System.out.println("Pairs:" + i); | |
55 | oneTest(i, iters); | |
56 | Thread.sleep(100); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |