asyncJob.h

Go to the documentation of this file.

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


#pragma once

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

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

#include "tbb/task.h"

#include "boost/function.hpp"


#include <vrfutil/vrfutilDefines.h>

class DtAsyncJob;

struct job_canceled{}; //exception for termination of a task during execution.
struct outside_search_radius{}; //exception for graph search has gone too far out of the way.

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:
   DtAsyncJob();

   virtual ~DtAsyncJob();

   virtual task* execute();

   virtual task* onExecute() = 0;
   virtual task* onException() = 0;

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

   virtual void setEntry(boost::shared_ptr<DtAsyncJobMapEntry>);
   
protected:
   boost::weak_ptr<DtAsyncJobMapEntry> myEntry;
   DtAsyncJobServer* myServer;
};