Threader.h

Go to the documentation of this file.

#ifndef _MADARA_THREADS_THREADER_H_
#define _MADARA_THREADS_THREADER_H_

#include <string>
#include <vector>
#include <map>
#include <list>
#include "madara/knowledge/KnowledgeBase.h"
#include "BaseThread.h"
#include "WorkerThread.h"
#include "madara/MADARA_export.h"

#ifdef _MADARA_JAVA_
#include <jni.h>
#include "madara_jni.h"
#endif

namespace madara
{
  namespace threads
  {
    class MADARA_Export Threader
    {
    public:
      Threader ();

      Threader (knowledge::KnowledgeBase & data_plane);

      ~Threader ();

      void change_hertz (const std::string name, double hertz);

      knowledge::KnowledgeBase get_control_plane (void);

      knowledge::KnowledgeBase get_data_plane (void);

      void pause (const std::string name);

      void pause (void);

      void resume (const std::string name);

      void resume (void);

      void run (const std::string name, BaseThread * thread,
        bool paused = false);
      
      void run (double hertz, const std::string name, BaseThread * thread,
        bool paused = false);
      
#ifdef _MADARA_JAVA_
      
      void run (const std::string name, jobject thread, bool paused = false);
      
      void run (double hertz, const std::string name, jobject thread,
        bool paused = false);
      
#endif

      void set_data_plane (knowledge::KnowledgeBase & data_plane);

      void terminate (const std::string name);

      void terminate (void);

      bool wait (const std::string name,
        const knowledge::WaitSettings & ws = knowledge::WaitSettings ());

      bool wait (
        const knowledge::WaitSettings & ws = knowledge::WaitSettings ());
      
    private:
      
      knowledge::KnowledgeBase * data_;

      knowledge::KnowledgeBase * control_;

      NamedWorkerThreads threads_;
    };
  }
}

#include "Threader.inl"

#endif  // _MADARA_THREADS_THREADER_H_