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);
   }

};


#endif


}

#endif