Searched defs:Producer (Results 1 - 5 of 5) sorted by relevance
/openjdk7/jdk/test/java/util/concurrent/ExecutorCompletionService/ |
H A D | ExecutorCompletionServiceLoops.java | 86 static class Producer implements Runnable { class in class:ExecutorCompletionServiceLoops 89 Producer(ExecutorCompletionService ecs, int i) { method in class:ExecutorCompletionServiceLoops.Producer 101 new Thread(new Producer(ecs, iters)).start();
|
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | CancelledProducerConsumerLoops.java | 86 prods[i] = pool.submit(new Producer(q, barrier, iters)); 146 static class Producer extends Stage { class in class:CancelledProducerConsumerLoops 147 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:CancelledProducerConsumerLoops.Producer
|
H A D | SingleProducerMultipleConsumerLoops.java | 101 static class Producer extends Stage { class in class:SingleProducerMultipleConsumerLoops 102 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:SingleProducerMultipleConsumerLoops.Producer 158 pool.execute(new Producer(q, barrier, iters * nconsumers));
|
H A D | MultipleProducersSingleConsumerLoops.java | 119 static class Producer extends Stage { class in class:MultipleProducersSingleConsumerLoops 120 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:MultipleProducersSingleConsumerLoops.Producer 174 pool.execute(new Producer(q, barrier, iters));
|
H A D | ProducerConsumerLoops.java | 116 static class Producer extends Stage { class in class:ProducerConsumerLoops 117 Producer(BlockingQueue<Integer> q, CyclicBarrier b, int iters) { method in class:ProducerConsumerLoops.Producer 172 pool.execute(new Producer(q, barrier, iters));
|
Completed in 33 milliseconds