asyncJob.h

Go to the documentation of this file.

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


#pragma once

#include <vrfutil/vrfutilDefines.h>

#include <vlutil/vlPrint.h>
#include <vlutil/vlExceptions.h>

#include "asyncJobMapEntry.h"
#include "asyncJobServer.h"

#include "vrfutil/algorithmManager.h"
#include "vrfutil/objectCounter.h"

#include <tbb/task.h>

#include <boost/function.hpp>

class DtAsyncJob;

struct job_canceled{};

class DT_DLL_vrfutil DtJobCancelledFunc
{ 
public:
   DtJobCancelledFunc(const DtAsyncJob& job);
   bool operator()() const;

protected:
   const DtAsyncJob& job;
};

class DT_DLL_vrfutil DtAsyncJob
   : public tbb::task
   , public DtAlgorithmManager
   , public DtObjectDebugger<DtAsyncJob>
{
public:
   DtAsyncJob();

   virtual ~DtAsyncJob();

   virtual task* execute();

   virtual task* onExecute() = 0;

   virtual task* onException() = 0;

   virtual void tick();

   virtual boost::shared_ptr<DtAsyncJobMapEntry> getEntry() const = 0;

   virtual void setEntry(boost::shared_ptr<DtAsyncJobMapEntry>) = 0;

   bool cancel() const;
   
protected:
   DtAsyncJobServer* myServer;
};

class DT_DLL_vrfutil DtAsyncManagedJob : public DtAsyncJob
{
public:
   boost::shared_ptr<DtAsyncJobMapEntry> getEntry() const;
   void setEntry(boost::shared_ptr<DtAsyncJobMapEntry>);

protected:
   boost::weak_ptr<DtAsyncJobMapEntry> myEntry;
};

class DT_DLL_vrfutil DtAsyncDetachedJob : public DtAsyncJob
{
public:
   boost::shared_ptr<DtAsyncJobMapEntry> getEntry() const;
   void setEntry(boost::shared_ptr<DtAsyncJobMapEntry>);

   task* execute();

protected:
   boost::shared_ptr<DtAsyncJobMapEntry> myEntry;
};

DT_DEFINE_OBJECT_DEBUGGER_NAME(DtAsyncJob);