StoppableThread.h

Go to the documentation of this file.

#ifndef _STOPPABLETHREAD_H_
#define _STOPPABLETHREAD_H_

#ifndef __CINT__
#include <atomic>
#include <condition_variable>
#include <thread>
#endif

#include <string>

#include "TObject.h"

class StoppableThread {
public:
  StoppableThread();
  virtual ~StoppableThread();

  void Resume();
  void Pause();
  void Stop();
  bool IsPaused();
  bool IsRunning();
  void Join();

  virtual std::string Status() { return ""; }

protected:
  virtual bool Iteration() = 0;

private:
  StoppableThread(const StoppableThread& other) { }
  StoppableThread& operator=(const StoppableThread& other) { }

  void Loop();

#ifndef __CINT__
  std::thread thread;
  std::atomic_bool running;
  std::atomic_bool force_stop;
  std::atomic_bool paused;
  std::condition_variable paused_wait;
  std::mutex pause_mutex;
#endif

  ClassDef(StoppableThread, 0);
};


#endif /* _STOPPABLETHREAD_H_ */