semaphore.hpp

Go to the documentation of this file.

#pragma once
#include "semaphore_full_exception.hpp"
#include "wait_handle.hpp"
#include "../icomparable.hpp"
#include "../iequatable.hpp"
#include "../int32_object.hpp"

namespace xtd {
  namespace threading {
    class core_export_ semaphore : public wait_handle, public icomparable<semaphore>, public iequatable<semaphore> {
      class semaphore_base;
      class named_semaphore;
      class unnamed_semaphore;
      struct data;
    public:
      
      semaphore();
      explicit semaphore(const string& name);
      explicit semaphore(const string& name, bool& created_new);
      explicit semaphore(int32 initial_count);
      semaphore(int32 initial_count, const string& name);
      semaphore(int32 initial_count, const string& name, bool& created_new);
      semaphore(int32 initial_count, int32 maximum_count);
      semaphore(int32 initial_count, int32 maximum_count, const string& name);
      semaphore(int32 initial_count, int32 maximum_count, const string& name, bool& created_new);
      
      template<class char_t>
      explicit semaphore(const char_t* name) : semaphore(string(name)) {}
      ~semaphore();
      
      
      [[nodiscard]] auto handle() const noexcept -> intptr override;
      auto handle(intptr value) -> void override;
      
      
      auto close() -> void override;
      
      [[nodiscard]] auto compare_to(const semaphore& value) const noexcept -> int32 override;
      
      [[nodiscard]] auto equals(const object& obj) const noexcept -> bool override;
      [[nodiscard]] auto equals(const semaphore& other) const noexcept -> bool override;
      
      auto release() -> int32;
      auto release(int32 release_count) -> int32;
      
      
      [[nodiscard]] static auto open_existing(const string& name) -> semaphore;
      
      [[nodiscard]] static auto try_open_existing(const string& name, semaphore& result) noexcept -> bool;
      
    protected:
      
      auto signal() -> bool override;
      
      auto wait(int32 milliseconds_timeout) -> bool override;
      
    private:
      auto create(int32 initial_count, int32 maximum_count, bool& created_new) -> void;
      xtd::sptr<semaphore_base> semaphore_;
      xtd::sptr<data> data_;
    };
  }
}