Package jconch.pipeline.impl

Class Summary

BoundedPipeLink<T>	A pipe link with a specified upper bound on the queue length.
ClosureConsumer	A Closure-based implementation of a Consumer.
CollectionConsumer<T>	A consumer which collects elements into a collection.
CollectionProducer<T>	A producer which provides elements from a given collection.
ExceptionThreadingModel	Class that explodes when ExceptionThreadingModel.execute(PipelineStage) is called.
ExecutorThreadingModel	A wrapper around ThreadingModel which allows the user to leverage the Executor API, and its myriad extensions.
FactoryProducer	A Producer based off of a Factory implementation.
InlineThreadingModel	Executes the pipeline stage inline.
SingleThreadThreadingModel	Runs a single different thread to process the threading.
SpawningThreadingModel	Spawns a new thread for each call to execute.
TransformerProcessor	A Transformer-based implementation of a Processor.
UnboundedPipeLink<T>	An unbounded link in the pipeline.