|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use StageDriver | |
---|---|
org.apache.commons.pipeline | This package provides a set of pipeline utilities designed around work queues that run in parallel to sequentially process data objects. |
org.apache.commons.pipeline.driver | This package contains implementations of the StageDriver and StageDriverFactory interfaces. |
Uses of StageDriver in org.apache.commons.pipeline |
---|
Classes in org.apache.commons.pipeline with type parameters of type StageDriver | |
---|---|
interface |
StageDriverFactory<T extends StageDriver>
This interface represents a factory that is used by a Pipeline to create
a driver for a Stage when that stage is added to the pipeline. |
Methods in org.apache.commons.pipeline that return StageDriver | |
---|---|
StageDriver |
Pipeline.getStageDriver(Stage stage)
Return the StageDriver for the specified Stage. |
Methods in org.apache.commons.pipeline that return types with arguments of type StageDriver | |
---|---|
List<StageDriver> |
Pipeline.getStageDrivers()
Returns an unmodifiable list of stage drivers that have been added to the pipeline. |
Uses of StageDriver in org.apache.commons.pipeline.driver |
---|
Classes in org.apache.commons.pipeline.driver that implement StageDriver | |
---|---|
class |
AbstractStageDriver
This interface is used to define how processing for a stage is started, stopped, and run. |
class |
DedicatedThreadStageDriver
This is a very simple implementation of a AbstractStageDriver which spawns a single thread to process a stage. |
class |
SynchronousStageDriver
This is a non-threaded version of the AbstractStageDriver. |
class |
ThreadPoolStageDriver
This StageDriver implementation uses a pool of threads
to process objects from an input queue. |
Methods in org.apache.commons.pipeline.driver that return StageDriver | |
---|---|
StageDriver |
ThreadPoolStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates the new ThreadPoolStageDriver based upon the configuration
of this factory instance |
StageDriver |
SynchronousStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates a new SynchronousStageDriver based upon this factory's configuration. |
StageDriver |
DedicatedThreadStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates the new DedicatedThreadStageDriver based upon the configuration
of this factory instance |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |