semaphore.h

Go to the documentation of this file.

#ifndef ION_PORT_SEMAPHORE_H_
#define ION_PORT_SEMAPHORE_H_

#if defined(ION_PLATFORM_IOS) || defined(ION_PLATFORM_MAC)
#include <dispatch/dispatch.h>
#elif defined(ION_PLATFORM_WINDOWS)
#include <windows.h>
#include <atomic>
#else
#include <semaphore.h>
#endif

#include "base/integral_types.h"
#include "base/macros.h"

namespace ion {
namespace port {

class ION_API Semaphore {
 public:
  Semaphore();
  explicit Semaphore(uint32 initial_value);
  ~Semaphore();

  bool Post();
  bool Wait();
  bool TryWait();
  bool TimedWaitMs(int64 timeout_in_ms);

 private:
#if defined(ION_PLATFORM_IOS) || defined(ION_PLATFORM_MAC)
  dispatch_semaphore_t semaphore_;
#elif defined(ION_PLATFORM_WINDOWS)
  HANDLE semaphore_;
  std::atomic<int> value_;
#elif defined(ION_PLATFORM_ASMJS)
  int value_;
#else
  sem_t semaphore_;
#endif

  DISALLOW_COPY_AND_ASSIGN(Semaphore);
};

}  // namespace port
}  // namespace ion

#endif  // ION_PORT_SEMAPHORE_H_