39 #ifndef LINEAR_PIPELINE_HPP__
40 #define LINEAR_PIPELINE_HPP__
44 #include <boost/bind.hpp>
45 #include <boost/thread.hpp>
46 #include <boost/shared_ptr.hpp>
50 template<
typename WorkTypeA,
typename WorkTypeB>
58 void AddStage(boost::shared_ptr<AbstractStage > stage)
72 boost::shared_ptr<BlockingQueue >(
78 boost::shared_ptr<BlockingQueue >(
105 for(
size_t i=0; i<
m_stages.size(); ++i)
108 boost::shared_ptr<boost::thread>(
new boost::thread(
117 for(
size_t i=0; i<
m_stages.size(); ++i)
131 boost::shared_ptr<AbstractStage >
135 boost::shared_ptr<BlockingQueue >
139 boost::shared_ptr<boost::thread>
142 #endif // LinearPipeline_h__