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

/openjdk7/jdk/test/java/util/concurrent/ExecutorCompletionService/
H A DExecutorCompletionServiceLoops.java86 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 DCancelledProducerConsumerLoops.java86 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 DSingleProducerMultipleConsumerLoops.java101 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 DMultipleProducersSingleConsumerLoops.java119 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 DProducerConsumerLoops.java116 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 48 milliseconds