Lines Matching refs:consumers
39 * @summary check ordering for blocking queues with 1 producer and multiple consumers
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);