Searched defs:Consumer (Results 1 - 5 of 5) sorted by relevance

/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DCancelledProducerConsumerLoops.java87 cons[i] = pool.submit(new Consumer(q, barrier, iters));
165 static class Consumer extends Stage { class in class:CancelledProducerConsumerLoops
166 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:CancelledProducerConsumerLoops.Consumer
H A DSingleProducerMultipleConsumerLoops.java122 static class Consumer extends Stage { class in class:SingleProducerMultipleConsumerLoops
123 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:SingleProducerMultipleConsumerLoops.Consumer
160 pool.execute(new Consumer(q, barrier, iters));
H A DMultipleProducersSingleConsumerLoops.java145 static class Consumer extends Stage { class in class:MultipleProducersSingleConsumerLoops
146 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:MultipleProducersSingleConsumerLoops.Consumer
176 pool.execute(new Consumer(q, barrier, iters * nproducers));
H A DProducerConsumerLoops.java141 static class Consumer extends Stage { class in class:ProducerConsumerLoops
142 Consumer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:ProducerConsumerLoops.Consumer
173 pool.execute(new Consumer(q, barrier, iters));
/openjdk7/jdk/src/solaris/demo/jni/Poller/
H A DPollingServer.java66 * data (bytesRead,eventsToProcess) by concurrent Consumer threads.
118 new Consumer(consumerThread).start();
221 class Consumer extends Thread { class in class:PollingServer
223 public Consumer(int i) { threadNumber = i; } method in class:PollingServer.Consumer

Completed in 57 milliseconds