SonicDispatcherPseudoAsync.h

Go to the documentation of this file.

#ifndef HeterogeneousCore_SonicCore_SonicDispatcherPseudoAsync
#define HeterogeneousCore_SonicCore_SonicDispatcherPseudoAsync
 
#include "HeterogeneousCore/SonicCore/interface/SonicDispatcher.h"
 
#include <memory>
#include <condition_variable>
#include <mutex>
#include <thread>
#include <atomic>
#include <exception>
 
class SonicClientBase;
 
//pretend to be async + non-blocking by waiting for blocking calls to return in separate std::thread
class SonicDispatcherPseudoAsync : public SonicDispatcher {
public:
  //constructor
  SonicDispatcherPseudoAsync(SonicClientBase* client);
 
  //destructor
  ~SonicDispatcherPseudoAsync() override;
 
  //main operation
  void dispatch(edm::WaitingTaskWithArenaHolder holder) override;
 
private:
  void waitForNext();
 
  //members
  bool hasCall_;
  std::mutex mutex_;
  std::condition_variable cond_;
  std::atomic<bool> stop_;
  std::unique_ptr<std::thread> thread_;
};
 
#endif