Import xayon thread utility

utilityThread/Thread.cpp

@@ -0,0 +1,98 @@
+#include "Thread.h"
+
+Thread::Thread(): m_isstop(true), m_autoDelete(false)
+{
+
+}
+Thread::~Thread()
+{
+    if(!m_isstop)
+    {
+        SDL_KillThread(m_t);
+        m_t = 0;
+    }
+    for(std::map<std::string, SDL_mutex*>::iterator mutex = m_mutexs.begin();mutex != m_mutexs.end();mutex++)
+        SDL_DestroyMutex(mutex->second);
+}
+bool Thread::start()
+{
+    if(m_isstop)
+    {
+        m_t = SDL_CreateThread(Thread::ThreadInit, this);
+        if(m_t != 0)
+        {
+            m_isstop = false;
+            return true;
+        }
+    }
+    return false;
+}
+void Thread::stop()
+{
+    if(!m_isstop)
+    {
+        SDL_KillThread(m_t);
+        m_t = 0;
+    }
+    m_isstop = true;
+}
+void Thread::join()
+{
+    SDL_WaitThread(m_t, 0);
+    m_isstop = true;
+}
+void Thread::setAutoDelete(bool autoDelete)
+{
+    m_autoDelete = autoDelete;
+}
+
+int Thread::ThreadInit(void* param)
+{
+    Thread *t(reinterpret_cast<Thread*>(param));
+    t->run();
+    if(t->m_autoDelete)
+        delete t;
+    return 0;
+}
+
+bool Thread::threadRunning()
+{
+    return m_isstop;
+}
+
+bool Thread::createLockMutex(std::string name)
+{
+    std::map<std::string, SDL_mutex*>::iterator mutex = m_mutexs.find(name);
+
+    if(m_mutexs.find(name) == m_mutexs.end())
+    {
+        m_mutexs[name] = SDL_CreateMutex();
+        mutex = m_mutexs.find(name);
+    }
+    if(SDL_mutexP(mutex->second)==-1)
+        return false;
+
+    return true;
+}
+bool Thread::lockMutex(std::string name)
+{
+    std::map<std::string, SDL_mutex*>::iterator mutex = m_mutexs.find(name);
+
+    if(m_mutexs.find(name) == m_mutexs.end())
+        return false;
+    if(SDL_mutexP(mutex->second)==-1)
+        return false;
+
+    return true;
+}
+bool Thread::unlockMutex(std::string name)
+{
+    std::map<std::string, SDL_mutex*>::iterator mutex = m_mutexs.find(name);
+
+    if(m_mutexs.find(name) == m_mutexs.end())
+        return false;
+    if(SDL_mutexV(mutex->second)==-1)
+        return false;
+
+    return true;
+}

utilityThread/Thread.h

@@ -0,0 +1,36 @@
+#ifndef THREAD_H
+#define THREAD_H
+
+#include <iostream>
+#include <map>
+#include <SDL_thread.h>
+
+class Thread
+{
+public:
+    Thread();
+    virtual ~Thread();// arrete automatiquement le thread meme si il est en cour
+    bool start();// demarre la fonction run() dans un thread
+    void stop();// arrete le thread
+    void join();// ratache la thread au processus principale qui est bloqué et attend que le run() se termine
+    void setAutoDelete(bool autoDelete);// permet de declarer dynamiquement une class qui erite de Thread sans garder le pointeur, il sera delete a la fin du thread si l'argument est true
+
+    bool threadRunning();
+
+    bool lockMutex(std::string name);
+    bool unlockMutex(std::string name);
+
+    virtual void run() = 0;// tout devra se passer ici
+
+protected:
+    bool createLockMutex(std::string name);
+
+private:
+    static int ThreadInit(void* param);
+    bool m_isstop;
+    SDL_Thread *m_t;
+    bool m_autoDelete;
+    std::map<std::string, SDL_mutex*> m_mutexs;
+};
+
+#endif // THREAD_H