Searched defs:CAPACITY (Results 1 - 6 of 6) sorted by relevance

/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DCancelledProducerConsumerLoops.java47 static final int CAPACITY = 100; field in class:CancelledProducerConsumerLoops
124 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
125 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
126 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
H A DSingleProducerMultipleConsumerLoops.java45 static final int CAPACITY = 100; field in class:SingleProducerMultipleConsumerLoops
77 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), consumers, iters);
78 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), consumers, iters);
79 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), consumers, iters);
86 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), consumers, iters);
H A DMultipleProducersSingleConsumerLoops.java45 static final int CAPACITY = 100; field in class:MultipleProducersSingleConsumerLoops
91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), producers, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), producers, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), producers, iters);
105 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), producers, iters);
H A DProducerConsumerLoops.java45 static final int CAPACITY = 100; field in class:ProducerConsumerLoops
91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), pairs, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), pairs, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), pairs, iters);
102 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), pairs, iters);
/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DExchanger.java226 private static final int CAPACITY = 32; field in class:Exchanger
230 * contention. When this value is less than CAPACITY, some
234 Math.max(0, Math.min(CAPACITY, NCPU / 2) - 1);
315 private volatile Slot[] arena = new Slot[CAPACITY];
H A DThreadPoolExecutor.java377 private static final int CAPACITY = (1 << COUNT_BITS) - 1; field in class:ThreadPoolExecutor
387 private static int runStateOf(int c) { return c & ~CAPACITY; }
388 private static int workerCountOf(int c) { return c & CAPACITY; }
537 * bounded by CAPACITY.
907 if (wc >= CAPACITY ||

Completed in 39 milliseconds