ControlThread.h

Go to the documentation of this file.

#ifndef CONTROLTHREAD_H_
#define CONTROLTHREAD_H_

#include "component/AsyncComponent.h"
#include "component/SyncComponent.h"
#include "process/SyncHandler.h"

static const double DEFAULT_CONTROL_THREAD_PERIOD = 0.4;

class ControlThread;

class ControlThread : public AsyncComponent
{
public:
    ControlThread();

    virtual ~ControlThread();

    virtual void initialize( void );

    virtual void run( void );

    virtual void uninitialize( void );

    //== Functions for dealing with the list of components ==
    void addComponent( SyncComponent *component );

    void removeComponent( SyncComponent *component );

    virtual Handler *getSyncHandler()
    {
        return & syncHandler_;
    }

private:

    SyncHandler syncHandler_;

    // Hm, ok, what if there were three lists, an "add me" list,
    // a "delete me" list and an actual "working" list.  Then
    // the thread could decide when to take action...
    //
    // It's possible that some of these lists will actually be of
    // intermediate "holder" objects to hold counts, metainfo, etc...
    ListOfSyncComponents componentsToAdd_;
    ListOfSyncComponents componentsToRemove_;
    Mutex addComponentsMutex_, removeComponentsMutex_;

    int addComponentsFromQueue( void );

    int removeComponentsFromQueue( void );
};


#endif /*CONTROLTHREAD_H_*/