Uses of Class
com.gengoai.concurrent.Broker.Producer

Packages that use Broker.Producer

Package	Description
com.gengoai.concurrent	Contains a custom fixed size executor and a Producer - Consumer framework for multithreaded tasks.

Uses of Broker.Producer in com.gengoai.concurrent

Subclasses of Broker.Producer in com.gengoai.concurrent

Modifier and Type	Class	Description
class	IterableProducer<V>	A producer implementation that produces items from an iterable.
class	StreamProducer<V>	A producer implementation that produces items from a stream

Methods in com.gengoai.concurrent with parameters of type Broker.Producer

Modifier and Type	Method	Description
Broker.Builder<V>	Broker.Builder.addProducer(Broker.Producer<V> producer)	Adds a producer
Broker.Builder<V>	Broker.Builder.addProducer(Broker.Producer<V> producer, int number)	Adds producer and sets it to run on a number of threads.

Method parameters in com.gengoai.concurrent with type arguments of type Broker.Producer

Modifier and Type	Method	Description
Broker.Builder<V>	Broker.Builder.addProducers(Collection<? extends Broker.Producer<V>> producers)	Adds a collection of producers.

Constructors in com.gengoai.concurrent with parameters of type Broker.Producer

Constructor	Description
BrokerIterator(Broker.Producer<T> producer, Function<? super T,Stream<? extends O>> converter, int bufferSize, int nThreads)	Instantiates a new Broker iterator.