Contains a custom fixed size executor and a Producer - Consumer framework for multithreaded tasks.
Class Summary Class Description AtomicDoubleThread safe double container BlockingThreadPoolExecutorA
ThreadPoolExecutorwhich 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 ThreadsConvenience methods for manipulating threads and processing data on multiple-threads