semaphore.h

Go to the documentation of this file.

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

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 ustring& name);
      explicit semaphore(const ustring& name, bool& created_new);
      explicit semaphore(int32 initial_count);
      semaphore(int32 initial_count, const ustring& name);
      semaphore(int32 initial_count, const ustring& name, bool& created_new);
      semaphore(int32 initial_count, int32 maximum_count);
      semaphore(int32 initial_count, int32 maximum_count, const ustring& name);
      semaphore(int32 initial_count, int32 maximum_count, const ustring& name, bool& created_new);

      template <typename char_t>
      explicit semaphore(const char_t* name) : semaphore(ustring(name)) {}
      ~semaphore();

      
      intptr handle() const noexcept override;
      void handle(intptr value) override;
      
      
      void close() override;
      
      int32 compare_to(const semaphore& value) const noexcept override;
      
      bool equals(const semaphore& value) const noexcept override;
      
      static semaphore open_existing(const ustring& name);

      int32 release();
      int32 release(int32 release_count);

      static bool try_open_existing(const ustring& name, semaphore& result) noexcept;

    protected:
      
      bool signal() override;

      bool wait(int32 milliseconds_timeout) override;

    private:
      void create(int32 initial_count, int32 maximum_count, bool& created_new);
      std::shared_ptr<semaphore_base> semaphore_;
      std::shared_ptr<data> data_;
    };
  }
}