Package org.apache.commons.pipeline.driver

This package contains implementations of the StageDriver and StageDriverFactory interfaces.

See:
Description

Class Summary

AbstractStageDriver	This interface is used to define how processing for a stage is started, stopped, and run.
DedicatedThreadStageDriver	This is a very simple implementation of a AbstractStageDriver which spawns a single thread to process a stage.
DedicatedThreadStageDriverFactory	This factory is used to create DedicatedThreadStageDriver instances configured to run specific stages.
SynchronousStageDriver	This is a non-threaded version of the AbstractStageDriver.
SynchronousStageDriverFactory	Factory for SynchronousStageDriver objects.
ThreadPoolStageDriver	This StageDriver implementation uses a pool of threads to process objects from an input queue.
ThreadPoolStageDriverFactory	This factory is used to create ThreadPoolStageDriver instances configured to run specific stages.

Enum Summary

FaultTolerance

Stores the failure tolerance flag for a worker thread.

Package org.apache.commons.pipeline.driver Description

This package contains implementations of the StageDriver and StageDriverFactory interfaces. These implementations define the threading models that are available for use in running a pipeline.