thread_manager.hpp

Go to the documentation of this file.

 
#ifndef THREAD_MANAGER_HPP
#define THREAD_MANAGER_HPP
 
#include <atomic>
#include <future>
#include <mutex>
#include <thread>

class ThreadManager
{
public:
  struct ThreadState
  {
    std::mutex play_mutex;

    std::atomic<bool> is_processing{false};

    std::atomic<bool> is_playing{false};

    std::future<void> play_future;
  };

  ThreadState& getThreadState() { return thread_state; }

  void lockPlayMutex(ThreadState& thread_state)
  {
    std::unique_lock<std::mutex> lock(thread_state.play_mutex);
  }

  void unlockPlayMutex(ThreadState& thread_state) { thread_state.play_mutex.unlock(); }
 
private:
  ThreadState thread_state;
};
 
#endif // THREAD_MANAGER_HPP