Lines Matching refs:producers
39 * @summary multiple producers and single consumer using blocking queues
90 static void oneTest(int producers, int iters) throws Exception {
91 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY), producers, iters);
92 oneRun(new LinkedBlockingQueue<Integer>(CAPACITY), producers, iters);
93 oneRun(new LinkedBlockingDeque<Integer>(CAPACITY), producers, iters);
94 oneRun(new LinkedTransferQueue<Integer>(), producers, iters);
99 // oneRun(new PriorityBlockingQueue<Integer>(), producers, iters);
101 oneRun(new SynchronousQueue<Integer>(), producers, iters);
104 oneRun(new SynchronousQueue<Integer>(true), producers, iters);
105 oneRun(new ArrayBlockingQueue<Integer>(CAPACITY, true), producers, iters);