asyncJobServer.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright 2010 VT MAK
*******************************************************************************/



#pragma once


#include <stdlib.h>
#include <memory>
#include <list>

#include <tbb/concurrent_hash_map.h>
#ifdef WIN32
   #include <WinSock2.h>
#endif
#include <tbb/mutex.h>


class DtAsyncJob;
class DtAsyncJobToken;
class DtAsyncJobMapEntry;

enum DtAsyncJobStatus
{
   queued,
   processing,
   complete,
   canceled,
   error
};



typedef 
   void (*DtAsyncJobStatusChangedCallbackFcn)(DtAsyncJobStatus, DtAsyncJobToken*);

#include <vrfutil/vrfutilDefines.h>
class DT_DLL_vrfutil DtAsyncJobResult 
{
public:
   DtAsyncJobResult() {};
   
   virtual ~DtAsyncJobResult() {};
};

struct MyHashCompare 
{
   static size_t hash( const size_t& x ) 
   {
      return x;
   }
   
   static bool equal( const size_t& x, const size_t& y ) 
   {
      return x==y;
   }
};


typedef tbb::concurrent_hash_map<size_t, DtAsyncJobMapEntry*, MyHashCompare> DtAsyncJobMap;

class DT_DLL_vrfutil DtAsyncJobServer
{
public:
   DtAsyncJobServer();
   
   const DtAsyncJobResult* lookupAsyncJobResult(size_t id) const;

   virtual DtAsyncJobToken* addJob(std::auto_ptr<DtAsyncJob> job);

   virtual void cancelJob(size_t id);
   virtual void cancelAllJobs();
   bool empty();

   static size_t getId();

   virtual void markForRemoval(size_t id);

   virtual void cleanUpJobs();
   
   virtual DtAsyncJobStatus jobStatus(size_t id);

   virtual bool accessor(DtAsyncJobMap::accessor& a, size_t id);

   virtual void printAsyncJobMap();

protected:

   DtAsyncJobMap* myAsyncJobMap;

   static tbb::mutex theIdGenMutex;
   static size_t theNextId;

   static tbb::mutex theJobRemovalQueueMutex;
   std::list<size_t> myJobsToRemove;
};