runnable_batch.h

Go to the documentation of this file.

#ifndef CVD_INCLUDE_RUNNABLE_BATCH_H
#define  CVD_INCLUDE_RUNNABLE_BATCH_H

#include <cvd/thread.h>
#include <tr1/memory>
#include <vector>
namespace CVD
{

//Forward declaration
template<class C> class MessageQueue;

class RunnableBatch
{
        private:
                bool joined;
                unsigned int  parallelism;

                class RunMessageInThread: public Thread
                {
                        public:
                                RunMessageInThread(MessageQueue<std::tr1::shared_ptr<Runnable> >* queue);
                                virtual void run();

                        private:
                                MessageQueue<std::tr1::shared_ptr<Runnable> >* q;
                };
        
                std::vector<std::tr1::shared_ptr<RunMessageInThread> > threads;
                std::tr1::shared_ptr<MessageQueue<std::tr1::shared_ptr<Runnable> > > queue;
        

        public:
                RunnableBatch(unsigned int p);
                                
                void join();
                
                void schedule(std::tr1::shared_ptr<Runnable> r);
        
                ~RunnableBatch();
};

}
#endif

---

libcvd
Author(s): Edward Rosten, Paul Smith, Tom Drummond, Gerhard Reitmayr, Ethan Eade, Timothy Gan, Chris Kemp, Georg Klein
autogenerated on Fri Jan 11 09:13:10 2013