callbackQueue.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2013 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/


#pragma once

#include "vrfutil/vrfutilDefines.h"

#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>

#include <tbb/mutex.h>
#include <tbb/tbb_thread.h>
#include <tbb/compat/condition_variable>

#include <list>

class DT_DLL_vrfutil DtCallbackQueue
{
public:
   typedef boost::function<void ()> Callback;

   explicit DtCallbackQueue(unsigned maxTasks);
   ~DtCallbackQueue();

   void add(Callback);

   bool pop(Callback&);

   bool runOne();

private:
   void execute();

   typedef tbb::mutex Mutex;
   typedef tbb::interface5::condition_variable Condition;
   typedef tbb::interface5::unique_lock<Mutex> Lock;
   typedef std::list< boost::shared_ptr<tbb::tbb_thread> > ThreadList;
   typedef std::list<Callback> CallbackList;

   mutable Mutex myMutex;
   mutable Condition myCondition;
   bool myShutdownFlag;
   ThreadList myThreads;
   CallbackList myCallbacks;
};