cvd/runnable_batch.h

#ifndef CVD_INCLUDE_RUNNABLE_BATCH_H
#define  CVD_INCLUDE_RUNNABLE_BATCH_H

#include <cvd/runnable.h>
#if defined WIN32 && !defined __MINGW32__
#include <memory>
#else
#include <tr1/memory>
#endif
#include <vector>
namespace CVD
{
    //Why couldn't VS put TR1in the correct namespace?
    namespace tr1
    {
        using namespace std;
        using namespace std::tr1;
    }
    
    class Thread;

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

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

        class RunMessageInThread;

        std::vector<CVD::tr1::shared_ptr<RunMessageInThread> > threads;
        CVD::tr1::shared_ptr<MessageQueue<CVD::tr1::shared_ptr<Runnable> > > queue;
    

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

}
#endif