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

Packages that use Broker.Builder

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

Uses of Broker.Builder in com.gengoai.concurrent

Methods in com.gengoai.concurrent that return Broker.Builder

Modifier and Type	Method	Description
Broker.Builder<V>	Broker.Builder.addConsumer(Consumer<? super V> consumer)	Adds a consumer.
Broker.Builder<V>	Broker.Builder.addConsumer(Consumer<? super V> consumer, int number)	Adds a consumer and will run it on a number of threads.
Broker.Builder<V>	Broker.Builder.addConsumers(Collection<? extends Consumer<? super V>> consumers)	Add a collection of consumers.
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.
Broker.Builder<V>	Broker.Builder.addProducers(Collection<? extends Broker.Producer<V>> producers)	Adds a collection of producers.
Broker.Builder<V>	Broker.Builder.bufferSize(int size)	The size of the buffer.
static <V> Broker.Builder<V>	Broker.builder()	Creates a Builder to construct Broker instances.