Lines Matching defs:iters
66 int iters = 10000;
82 oneTest(i, iters);
90 static void oneTest(int pairs, int iters) throws Exception {
91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
94 oneRun(new LinkedTransferQueue<Integer>(), pairs, iters);
95 oneRun(new PriorityBlockingQueue<Integer>(), pairs, iters);
96 oneRun(new SynchronousQueue<Integer>(), pairs, iters);
101 oneRun(new SynchronousQueue<Integer>(true), pairs, iters);
102 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), pairs, iters);
106 final int iters;
109 Stage(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
112 this.iters = iters;
117 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
118 super(q, b, iters);
126 for (int i = 0; i < iters; ++i) {
142 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) {
143 super(q, b, iters);
151 for (int i = 0; i < iters; ++i) {
166 static void oneRun(BlockingQueue<Integer> q, int npairs, int iters) throws Exception {
172 pool.execute(new Producer(q, barrier, iters));
173 pool.execute(new Consumer(q, barrier, iters));
180 System.out.println("\t: " + LoopHelpers.rightJustify(time / (iters * npairs)) + " ns per transfer");