Threading.h

Go to the documentation of this file.

#ifndef EVE_THREADING_H
#define EVE_THREADING_H

#include "../eve-core.h"
#include "utils/Singleton.h"

class Threading
: public Singleton<Threading>
{
public:
    Threading();
    ~Threading();

    void Initialize();
    void RunLoop();
    void Process();
    void AddSocket(SOCKET soc);
    void AddThread(pthread_t thread);
    void RemoveThread(pthread_t thread);
    void CreateThread(void *(*start_routine) (void *), void *args);
    void EndThreads();
    void ListThreads();


    uint8 Count()                           { return (uint8)(m_threads.size()); }

protected:
    char* buf;
    fd_set rSoc, wSoc;
    struct timeval tv;

    uint8 nfds;
    uint8 sleepTime;
    uint32 bufferLen;

private:
    std::vector<pthread_t> m_threads;
};

//Singleton
#define sThread \
    ( Threading::get() )

#endif  // EVE_THREADING_H