Thread.h

Go to the documentation of this file.

//========================================================================
// Copyright (c) 2014 Yannick Pflanzer <scary-squid.de>
//
// This software is provided 'as-is', without any express or implied
// warranty. In no event will the authors be held liable for any damages
// arising from the use of this software.
//
// Permission is granted to anyone to use this software for any purpose,
// including commercial applications, and to alter it and redistribute it
// freely, subject to the following restrictions:
//
// 1. The origin of this software must not be misrepresented; you must not
//    claim that you wrote the original software. If you use this software
//    in a product, an acknowledgment in the product documentation would
//    be appreciated but is not required.
//
// 2. Altered source versions must be plainly marked as such, and must not
//    be misrepresented as being the original software.
//
// 3. This notice may not be removed or altered from any source
//    distribution.
//
//========================================================================

#ifndef __THREAD_H
#define __THREAD_H

namespace Neo
{
class NEO_CORE_EXPORT Thread
{
private:
        bool m_running; 
public:
    Thread() {}

    ~Thread() {}

    virtual bool Start(int (*thread_func)(void*), const char* name, void* data) = 0;

    virtual void Stop() = 0;

    virtual int WaitForReturn() = 0;

    bool IsRunning() { return m_running; }
    void SetRunning(bool value) { m_running = value; }

    virtual int GetId() = 0;

    virtual Thread* getNew() = 0;
};

class NEO_CORE_EXPORT Semaphore
{
public:
    Semaphore(){};
    ~Semaphore(){};

    virtual bool Init(int num) = 0;

    static bool WaitAndLock(Semaphore*);
    static bool Unlock(Semaphore*);

    virtual bool WaitAndLock() = 0;
    virtual bool Unlock() = 0;

    virtual Semaphore* getNew() = 0;

};

class NEO_CORE_EXPORT ThreadFactory
{
    Thread* m_templateThread;
    Semaphore* m_templateSemaphore;
public:

    static ThreadFactory* getInstance();

    void clear() { SAFE_DELETE(m_templateThread); SAFE_DELETE(m_templateSemaphore); }

    void setTemplateThread(Thread* thr) { m_templateThread = thr; }

    void setTemplateSemaphore(Semaphore* sem) { m_templateSemaphore = sem; }

    Thread* getNewThread() { if(m_templateThread) return m_templateThread->getNew(); else return NULL; }

    Semaphore* getNewSemaphore() { if(m_templateSemaphore) return m_templateSemaphore->getNew(); else return NULL; }
};
}
#endif // MTHREAD_H