Lines Matching refs:items
38 * @summary Checks that a set of threads can repeatedly get and modify items
54 int items = 1024 * 1024;
60 queues.add(new ArrayBlockingQueue<Integer>(items, false));
79 items = Integer.parseInt(args[1]);
92 oneRun(1, items, q);
94 oneRun(3, items, q);
99 oneRun(i, items, q);
108 int items;
109 Stage(Queue<Integer> q, CyclicBarrier b, int items) {
112 this.items = items;
135 if (items > 0) {
136 --items;
148 void oneRun(int n, int items, final Queue<Integer> q) throws Exception {
151 totalItems = new AtomicInteger(n * items);
154 results.add(pool.submit(new Stage(q, barrier, items)));
168 System.out.println(LoopHelpers.rightJustify(time / (items * n)) + " ns per item");