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