public class MultiThreadProducer<E> extends AbstractProducer<E>
queue
Constructor and Description |
---|
MultiThreadProducer(BlockingQueue<QueueEntry<E>> queue) |
public MultiThreadProducer(BlockingQueue<QueueEntry<E>> queue)
public void produce(Callable<E> callable)
produce
in class AbstractProducer<E>
public void awaitTermination()
awaitTermination
in class AbstractProducer<E>
public void stop()
stop
in class AbstractProducer<E>
Copyright © 2013. All Rights Reserved.