ExecutorMultiplexer.hpp

Go to the documentation of this file.

#ifndef AIKIDO_COMMON_EXECUTORMULTIPLEXER_HPP_
#define AIKIDO_COMMON_EXECUTORMULTIPLEXER_HPP_
 
#include <functional>
#include <mutex>
#include <vector>
 
namespace aikido {
namespace common {
 
class ExecutorMultiplexer final
{
public:
  ExecutorMultiplexer() = default;
 
  ~ExecutorMultiplexer() = default;
 
  void addCallback(std::function<void()> callback);
 
  void removeAllCallbacks();
 
  bool isEmpty() const;
 
  std::size_t getNumCallbacks() const;
 
  void operator()();
 
private:
  mutable std::mutex mMutex;
 
  std::vector<std::function<void()>> mCallbacks;
};
 
} // namespace common
} // namespace aikido
 
#endif // AIKIDO_COMMON_EXECUTORMULTIPLEXER_HPP_