PollThread.h

Go to the documentation of this file.

#ifndef __DCL_POLL_THREAD_H__
#define __DCL_POLL_THREAD_H__       20110224
 
#ifndef __DCL_CONFIG_H__
#include <dcl/Config.h>
#endif
 
#ifndef __DCL_POLL_ABLE_H__
#include <dcl/PollAble.h>
#endif
#ifndef __DCL_THREAD_H__
#include <dcl/Thread.h>
#endif
#ifndef __DCL_LIST_T_H__
#include <dcl/ListT.h>
#endif
 
__DCL_BEGIN_NAMESPACE

class DCLCAPI PollThread : public Thread
{
    DECLARE_CLASSINFO(IoPollThread)
public:
    PollThread(const char_t* _name = NULL);

    virtual bool add(PollAble* _pPollAble, short _events)
        __DCL_THROWS1(IOException*);

    virtual bool remove(PollAble* _pPollAble);

    void terminate();
 
protected:
    virtual int run();

    virtual void onRemoved(PollAble* _pPollAble);
 
    struct Update
    {
        PollAble*   pPollAble;
        bool        bAdd;
 
        Update() {
            pPollAble = NULL;
            bAdd = false;
        }
 
        Update(PollAble* _pPollAble, bool _bAdd)
        {
            this->pPollAble = _pPollAble;
            this->bAdd = _bAdd;
        }
    };
#ifdef _MSC_VER
#pragma warning (push)
#pragma warning (disable: 4251)
#endif
    typedef List<Update> UpdateList;
    UpdateList            __updateList;
    Thread::Mutex      __updateLock;
#ifdef _MSC_VER
#pragma warning (pop)
#endif
 
#if !__DCL_WINDOWS
    Thread::Event      __pollInterrupt;
#endif
    volatile bool       __terminate;
};
 
__DCL_END_NAMESPACE
 
#endif      // __DCL_POLL_THREAD_H__