cvd/runnable_batch.h

#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

---