RCWThread.h

Go to the documentation of this file.

#ifndef INCL_MADARA_THREADS_RCWTHREAD_H
#define INCL_MADARA_THREADS_RCWTHREAD_H

#include <string>
#include <vector>
#include <map>
#include <list>
#include <type_traits>
#include <initializer_list>
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/knowledge/Functions.h"
#include "madara/utility/StdInt.h"
#include "madara/MadaraExport.h"
#include "madara/knowledge/VariableReference.h"
#include "madara/knowledge/KnowledgeBase.h"
#include "madara/knowledge/KnowledgeCast.h"
#include "madara/knowledge/ContextGuard.h"
#include "madara/threads/BaseThread.h"
#include "madara/knowledge/rcw/Transaction.h"

namespace madara
{
  namespace threads
  {
    class MADARA_EXPORT RCWThread : public BaseThread
    {
    public:
      virtual ~RCWThread ()
      {
      }

      friend class WorkerThread;
      friend class Threader;

      virtual void setup (knowledge::rcw::Transaction &)
      {
      }

      virtual void compute (const knowledge::rcw::Transaction &) = 0;

      virtual void finalize (knowledge::rcw::Transaction &)
      {
      }

    private:
      virtual void init (knowledge::KnowledgeBase &kb) override final;

      virtual void run (void) override final;

      virtual void cleanup (void) override final;

      std::unique_ptr<knowledge::rcw::Transaction> tx_;
    };
  }
}

#endif  // INCL_MADARA_THREADS_RCWTHREAD_H