include/skepu/src/thread_management.h

Go to the documentation of this file.

#ifndef THREAD_MANAGEMENT_H
#define THREAD_MANAGEMENT_H

//Currently only works with pthreads in UNIX

#ifdef _WIN32
//Make win threads thing
#else
#include <pthread.h>
#endif

namespace skepu
{

#ifdef _WIN32
//Make win threads thing
#else

#define THREAD_FINISH pthread_exit(NULL);

class Threads
{

public:
    typedef pthread_t ThreadID;
    typedef void ThreadFuncArg;
    typedef void *(*ThreadFunc)(void*);

    void fork(ThreadFunc func, ThreadFuncArg* arg, ThreadID* thread)
    {
        int err;
        err = pthread_create(thread, NULL, func, arg);
        if(err) {std::cerr<<"ERROR creating threads\n";}
    }

    void join(ThreadID thread)
    {
        pthread_join(thread, NULL);
    }

    void cancel(ThreadID thread)
    {
        pthread_cancel(thread);
    }

};

// class Mutex
// {
// public:
//     Mutex()
//     {
//         pthread_mutex_init(&m_mutex, NULL);
//     }
//     ~Mutex()
//     {
//         pthread_mutex_destroy(&m_mutex);
//     }
//
//     void lock()
//     {
//         pthread_mutex_lock(&m_mutex);
//     }
//
//     void tryLock()
//     {
//         pthread_mutex_trylock(&m_mutex);
//     }
//
//     void unlock()
//     {
//         pthread_mutex_unlock(&m_mutex);
//     }
//
// private:
//     pthread_mutex_t m_mutex;
// };
//
// class Condition
// {
// public:
//     Condition()
//     {
//         pthread_cond_init(&m_condition, NULL);
//         pthread_mutex_init(&m_mutex, NULL);
//     }
//     ~Condition()
//     {
//         pthread_cond_destroy(&m_condition);
//         pthread_mutex_destroy(&m_mutex);
//     }
//
//     void signal()
//     {
//         pthread_cond_signal(&m_condition);
//     }
//
//     void wait()
//     {
//         pthread_cond_wait(&m_condition, &m_mutex);
//     }
//
//     void lock()
//     {
//         pthread_mutex_lock(&m_mutex);
//     }
//
//     void tryLock()
//     {
//         pthread_mutex_trylock(&m_mutex);
//     }
//
//     void unlock()
//     {
//         pthread_mutex_unlock(&m_mutex);
//     }
//
//
// private:
//     pthread_cond_t m_condition;
//     pthread_mutex_t m_mutex;
// };

#endif


}

#endif