callback_notifier.h

#include <atomic>
#include <condition_variable>
#include <mutex>
namespace ucxx {
 
namespace utils {

class CallbackNotifier {
 private:
  std::atomic_bool _flag{};                      //< flag storing state
  std::mutex _mutex{};                           //< lock to guard accesses
  std::condition_variable _conditionVariable{};  //< notification condition var
 
 public:
  CallbackNotifier() : _flag{false} {};
 
  ~CallbackNotifier() = default;
 
  CallbackNotifier(const CallbackNotifier&)            = delete;
  CallbackNotifier& operator=(CallbackNotifier const&) = delete;
  CallbackNotifier(CallbackNotifier&& o)               = delete;
  CallbackNotifier& operator=(CallbackNotifier&& o)    = delete;

  void set();

  bool wait(uint64_t period                                = 0,
            std::function<void(void)> signalWorkerFunction = nullptr,
            uint64_t signalRerun                           = 100000000);
};
 
}  // namespace utils
}  // namespace ucxx