Package com.gengoai.concurrent

Contains a custom fixed size executor and a Producer - Consumer framework for multithreaded tasks.

Class Summary

Class	Description
AtomicDouble	Thread safe double container
BlockingThreadPoolExecutor	A ThreadPoolExecutor which blocks when the queue of items to be executed becomes full.
Broker<V>	An implementation of the Producer Consumer problem in which one or more producers are generating data for one or more consumers to process.
Broker.Builder<V>	A Builder interface for constructing a Broker.
Broker.Producer<V>	A producer generates data to be consumed.
BrokerIterator<T,O>	The type Broker iterator.
IterableProducer<V>	A producer implementation that produces items from an iterable.
StreamProducer<V>	A producer implementation that produces items from a stream
Threads	Convenience methods for manipulating threads and processing data on multiple-threads