Lines Matching refs:iters
55 int iters = 1000000;
65 oneTest(i, iters);
77 static void oneRun(BlockingQueue<Integer> q, int npairs, int iters) throws Exception {
86 prods[i] = pool.submit(new Producer(q, barrier, iters));
87 cons[i] = pool.submit(new Consumer(q, barrier, iters));
122 static void oneTest(int pairs, int iters) throws Exception {
124 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
125 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
126 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
127 oneRun(new SynchronousQueue<Integer>(), pairs, iters / 8);
130 oneRun(new PriorityBlockingQueue<Integer>(iters / 2 * pairs), pairs, iters / 4);
131 oneRun(new LinkedTransferQueue<Integer>(), pairs, iters);
138 final int iters;
139 Stage(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
142 this.iters = iters;
147 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
148 super(q, b, iters);
155 for (int i = 0; i < iters; ++i) {
166 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
167 super(q, b, iters);
174 for (int i = 0; i < iters; ++i) {