// Copyright Oliver Kowalke 2013. // Distributed under the Boost Software License, Version 1.0. // (See accompanying file LICENSE_1_0.txt or copy at // http://www.boost.org/LICENSE_1_0.txt) #ifndef BOOST_FIBERS_TIMED_MUTEX_H #define BOOST_FIBERS_TIMED_MUTEX_H #include #include #include #include #include #include #include #include #ifdef BOOST_HAS_ABI_HEADERS # include BOOST_ABI_PREFIX #endif #ifdef _MSC_VER # pragma warning(push) # pragma warning(disable:4251) #endif namespace boost { namespace fibers { class condition_variable; class BOOST_FIBERS_DECL timed_mutex { private: friend class condition_variable; detail::spinlock wait_queue_splk_{}; wait_queue wait_queue_{}; context * owner_{ nullptr }; bool try_lock_until_( std::chrono::steady_clock::time_point const& timeout_time) noexcept; public: timed_mutex() = default; ~timed_mutex() { BOOST_ASSERT( nullptr == owner_); BOOST_ASSERT( wait_queue_.empty() ); } timed_mutex( timed_mutex const&) = delete; timed_mutex & operator=( timed_mutex const&) = delete; void lock(); bool try_lock(); template< typename Clock, typename Duration > bool try_lock_until( std::chrono::time_point< Clock, Duration > const& timeout_time_) { std::chrono::steady_clock::time_point timeout_time = detail::convert( timeout_time_); return try_lock_until_( timeout_time); } template< typename Rep, typename Period > bool try_lock_for( std::chrono::duration< Rep, Period > const& timeout_duration) { return try_lock_until_( std::chrono::steady_clock::now() + timeout_duration); } void unlock(); }; }} #ifdef _MSC_VER # pragma warning(pop) #endif #ifdef BOOST_HAS_ABI_HEADERS # include BOOST_ABI_SUFFIX #endif #endif // BOOST_FIBERS_TIMED_MUTEX_H