barrier.hpp

Go to the documentation of this file.

#pragma once
#include "barrier_post_phase_exception.hpp"
#include "cancellation_token.hpp"
#include "../action.hpp"
#include "../object.hpp"
#include "../time_span.hpp"

namespace xtd {
  namespace threading {
    class core_export_ barrier : public object {
      struct data;
    public:
      
      using post_phase_action = xtd::action<barrier&>;
      
      
      explicit barrier(xtd::size participant_count);
      barrier(xtd::size participant_count, barrier::post_phase_action post_phase_action);
      
      template<class post_phase_action_t>
      barrier(xtd::size participant_count, post_phase_action_t post_phase_action) : barrier(participant_count, barrier::post_phase_action {post_phase_action}) {}
      barrier();
      barrier(barrier&&) = default;
      barrier(const barrier&) = default;
      auto operator =(const barrier& other) -> barrier&;
      ~barrier();
      
      
      [[nodiscard]] auto current_phase_number() const -> xtd::size;
      
      [[nodiscard]] auto participant_count() const -> xtd::size;
      
      [[nodiscard]] auto participants_remaining() const -> xtd::size;
      
      
      auto add_participant() -> xtd::size;
      
      auto add_participants(xtd::size participant_count) -> xtd::size;
      
      auto close() -> void;
      
      auto remove_participant() -> xtd::size;
      
      auto remove_participants(xtd::size participant_count) -> xtd::size;
      
      auto signal_and_wait() -> void;
      auto signal_and_wait(xtd::int32 milliseconds_timeout) -> bool;
      auto signal_and_wait(const cancellation_token& cancellation_token) -> bool;
      auto signal_and_wait(const time_span& timeout) -> bool;
      auto signal_and_wait(xtd::int32 milliseconds_timeout, const cancellation_token& cancellation_token) -> bool;
      auto signal_and_wait(const time_span& timeout, const cancellation_token& cancellation_token) -> bool;
      
    private:
      auto wait_wtih_cancellation_token() -> bool;
      auto wait_wtih_cancellation_token(xtd::int32 milliseconds_timeout) -> bool;
      
      xtd::sptr<data> data_;
    };
  }
}