Lines Matching defs:iters
52 int iters = 10000;
68 oneTest(i, iters);
76 static void oneTest(int consumers, int iters) throws Exception {
77 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), consumers, iters);
78 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), consumers, iters);
79 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), consumers, iters);
80 oneRun(new LinkedTransferQueue<Integer>(), consumers, iters);
81 oneRun(new PriorityBlockingQueue<Integer>(), consumers, iters);
82 oneRun(new SynchronousQueue<Integer>(), consumers, iters);
85 oneRun(new SynchronousQueue<Integer>(true), consumers, iters);
86 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), consumers, iters);
90 final int iters;
94 Stage(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
97 this.iters = iters;
102 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
103 super(q, b, iters);
109 for (int i = 0; i < iters; ++i) {
123 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
124 super(q, b, iters);
133 for (int i = 0; i < iters; ++i) {
153 static void oneRun(BlockingQueue<Integer> q, int nconsumers, int iters) throws Exception {
158 pool.execute(new Producer(q, barrier, iters * nconsumers));
160 pool.execute(new Consumer(q, barrier, iters));
166 System.out.println("\t: " + LoopHelpers.rightJustify(time / (iters * nconsumers)) + " ns per transfer");