semaphore_decl.h

Go to the documentation of this file.

 
#ifndef A_UTIL_UTIL_CONCURRENCY_DETAIL_SEMAPHORE_DECL_HEADER_INCLUDED
#define A_UTIL_UTIL_CONCURRENCY_DETAIL_SEMAPHORE_DECL_HEADER_INCLUDED
 
#include <chrono>
 
namespace a_util {
namespace concurrency {
namespace detail {
template <typename Mutex, typename CondVar>
class basic_semaphore {
    basic_semaphore(const basic_semaphore&);            // = delete;
    basic_semaphore& operator=(const basic_semaphore&); // = delete;
 
public:
    explicit basic_semaphore(int count = 0);

    void notify();

    void wait();

    bool try_wait();

    template <typename Rep, typename Period>
    bool wait_for(const std::chrono::duration<Rep, Period>& timeout);

    void reset();

    bool is_set();
 
protected:
    Mutex _mutex;    
    CondVar _cv;     
    int _lock_count; 
};
 
} // namespace detail
} // namespace concurrency
} // namespace a_util

#include <a_util/concurrency/detail/semaphore_impl.h>
 
#endif // A_UTIL_UTIL_CONCURRENCY_DETAIL_SEMAPHORE_DECL_HEADER_INCLUDED