thread_pool.h

Go to the documentation of this file.

#ifndef DEVICE_H_A
#define DEVICE_H_A


#include <pthread.h>
#include <semaphore.h>
#include "thread_management.h"



#include <iostream>
#include <stdlib.h>
#include <vector>
#include <map>




namespace skepu
{

typedef void *(*ThreadFunc)(void *);

struct WorkerThread
{
   ThreadFunc job_func;
   void *job_arg;       /* its argument */

   unsigned virtual executeThis()
   {
      job_func(job_arg);
      return 0;
   }

   WorkerThread(ThreadFunc job, void *arg): job_func(job), job_arg(arg)
   {

   }

   ~WorkerThread()
   {
      job_func = NULL;
      job_arg = NULL;
   }
};

class ThreadPool
{
public:

   static pthread_mutex_t mutexSync;
   static pthread_mutex_t mutexWorkCompletion;

public:

   ThreadPool()
   {
      ThreadPool(2);
   }

   ThreadPool(int maxThreads)
   {
   }



   ~ThreadPool()
   {
   }


   void finishAll(int maxPollMilliSecs)
   {
   }


   void destroyPool(int maxPollMilliSecs)
   {
   }


   bool assignWork(WorkerThread *workerThread)
   {
      return true;
   }

   bool fetchWork(WorkerThread **workerArg)
   {
      return true;
   }

   void *threadExecute(void *param)
   {
      return 0;
   }


   void initializeThreads()
   {
   }

private:
   int maxThreads;

   pthread_cond_t  condCrit;
   sem_t availableWork;
   sem_t availableThreads;

   std::vector<WorkerThread *> workerQueue;

   int topIndex;
   int bottomIndex;

   int incompleteWork;


   int queueSize;

};

pthread_mutex_t ThreadPool::mutexSync = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t ThreadPool::mutexWorkCompletion = PTHREAD_MUTEX_INITIALIZER;

}


#endif