Searched defs:Consumer (Results 1 - 5 of 5) sorted by relevance
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | CancelledProducerConsumerLoops.java | 87 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 D | SingleProducerMultipleConsumerLoops.java | 122 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 D | MultipleProducersSingleConsumerLoops.java | 145 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 D | ProducerConsumerLoops.java | 141 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 D | PollingServer.java | 66 * 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