sharing_queue.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <condition_variable>
#include <functional>
#include <mutex>
#include <optional>
#include <policy/queue.hpp>
 
namespace fur::mt {
 
template <typename T>
class SharedQueue {
  policy::Queue<T> _work;
 
  mutable std::mutex _mutex;
  mutable std::condition_variable _new_work_available;
  mutable std::condition_variable _all_work_dispatched;
  bool _skip_waiting;
 
 public:
  // Error are the same of the queue
  using Error = typename policy::Queue<T>::Error;
  using Result = util::Result<T, Error>;
 
  // Function used to mutate the internal collection
  using MutateFn = typename policy::Queue<T>::MutateFn;
 
 public:
  SharedQueue();
 
  [[nodiscard]] Result try_extract(const policy::IPolicy<T>& policy);
 
  void insert(T&& work);
 
  template <typename... Args>
  void emplace(Args&&... args);
 
  void mutate(MutateFn mutation);
 
  void force_wakeup();
 
  void wait_work() const;
 
  void wait_empty() const;
 
  void begin_skip_waiting();
};
 
}  // namespace fur::mt
 
#include <mt/sharing_queue.inl>