source: experimental/Threading/Threading/ChannelWorker.h @ 420

#pragma once

#include <osg/Referenced>
#include <OpenThreads/Thread>
#include <OpenThreads/Barrier>


class ChannelWorker : public osg::Referenced, public OpenThreads::Thread
{
public:
        ChannelWorker(int numThreads, OpenThreads::Barrier& syncBarrier) ;
        ~ChannelWorker();
        virtual void run();
        virtual int cancel();
        
        void setDone(bool done);
        bool getDone() const { return _done; }

private:
        int _numThreads;
        bool _done;
        OpenThreads::Barrier& _syncBarrier;
};