condition_variable_any Class Reference

Public Member Functions
	condition_variable_any ()
	~condition_variable_any () _NOEXCEPT
	condition_variable_any (const condition_variable_any &)=delete
condition_variable_any &	operator= (const condition_variable_any &)=delete
void	notify_one () _NOEXCEPT
void	notify_all () _NOEXCEPT
template<class _Mutex >
void	wait (_Mutex &_Xtrnl)
template<class _Mutex , class _Predicate >
void	wait (_Mutex &_Xtrnl, _Predicate _Pred)
template<class _Lock , class _Rep , class _Period >
_Cv_status	wait_for (_Lock &_Lck, const chrono::duration< _Rep, _Period > &_Rel_time)
template<class _Lock , class _Rep , class _Period , class _Predicate >
bool	wait_for (_Lock &_Lck, const chrono::duration< _Rep, _Period > &_Rel_time, _Predicate _Pred)
template<class _Lock , class _Clock , class _Duration >
_Cv_status	wait_until (_Lock &_Lck, const chrono::time_point< _Clock, _Duration > &_Abs_time)
template<class _Lock , class _Clock , class _Duration , class _Predicate >
bool	wait_until (_Lock &_Lck, const chrono::time_point< _Clock, _Duration > &_Abs_time, _Predicate _Pred)
template<class _Mutex >
_Cv_status	wait_until (_Mutex &_Xtrnl, const xtime *_Abs_time)
template<class _Mutex , class _Predicate >
bool	wait_until (_Mutex &_Xtrnl, const xtime *_Abs_time, _Predicate _Pred)

Private Member Functions
_Cnd_t	_Mycnd () _NOEXCEPT

Static Private Member Functions
template<class _Mutex >
static void	_Relock (_Mutex &_Xtrnl) _NOEXCEPT

Private Attributes
shared_ptr< mutex >	_Myptr
aligned_storage< _Cnd_internal_imp_size, _Cnd_internal_imp_alignment >::type	_Cnd_storage

Constructor & Destructor Documentation

condition_variable_any::condition_variable_any ( )

inline

        {   // construct
        _Myptr = _STD make_shared<mutex>();
        _Cnd_init_in_situ(_Mycnd());
        }

condition_variable_any::~condition_variable_any ( )

inline

        {   // destroy
        _Cnd_destroy_in_situ(_Mycnd());
        }

condition_variable_any::condition_variable_any ( const condition_variable_any &  )

delete

Member Function Documentation

_Cnd_t condition_variable_any::_Mycnd ( )

inlineprivate

        {   // get pointer to _Cnd_internal_imp_t inside _Cnd_storage
        return (reinterpret_cast<_Cnd_t>(&_Cnd_storage));
        }

template<class _Mutex >

static void condition_variable_any::_Relock ( _Mutex &  _Xtrnl )

inlinestaticprivate

        {   // relocks external mutex, terminate() on failure
            // LWG 2135 says terminate rather than leaving the mutex unlocked;
            // we slam into noexcept here for that for easier user debugging
        _Xtrnl.lock();
        }

void condition_variable_any::notify_all ( )

inline

        {   // wake up all waiters
        lock_guard<mutex> _Lck(*_Myptr);
        _Cnd_broadcastX(_Mycnd());
        }

void condition_variable_any::notify_one ( )

inline

        {   // wake up one waiter
        lock_guard<mutex> _Lck(*_Myptr);
        _Cnd_signalX(_Mycnd());
        }

condition_variable_any& condition_variable_any::operator= ( const condition_variable_any &  )

delete

template<class _Mutex >

void condition_variable_any::wait ( _Mutex &  _Xtrnl )

inline

        {   // wait for signal
            {
            shared_ptr<mutex> _Ptr = _Myptr;    // for immunity to *this destruction
            lock_guard<mutex> _Lck(*_Ptr);
            _Xtrnl.unlock(); // could throw
            _Cnd_waitX(_Mycnd(), _Ptr->_Mymtx());
            }   // unlock

        _Relock(_Xtrnl);
        }

template<class _Mutex , class _Predicate >

void condition_variable_any::wait ( _Mutex &  _Xtrnl, _Predicate  _Pred  )

inline

        {   // wait for signal and check predicate
        while (!_Pred())
            wait(_Xtrnl);
        }

template<class _Lock , class _Rep , class _Period >

_Cv_status condition_variable_any::wait_for ( _Lock &  _Lck, const chrono::duration< _Rep, _Period > &  _Rel_time  )

inline

        {   // wait for duration
        stdext::threads::xtime _Tgt = _To_xtime(_Rel_time);
        return (wait_until(_Lck, &_Tgt));
        }

template<class _Lock , class _Rep , class _Period , class _Predicate >

bool condition_variable_any::wait_for ( _Lock &  _Lck, const chrono::duration< _Rep, _Period > &  _Rel_time, _Predicate  _Pred  )

inline

        {   // wait for signal with timeout and check predicate
        while (!_Pred())
            if (wait_for(_Lck, _Rel_time) == cv_status::timeout)
                return (_Pred());
        return (true);
        }

template<class _Lock , class _Clock , class _Duration >

_Cv_status condition_variable_any::wait_until ( _Lock &  _Lck, const chrono::time_point< _Clock, _Duration > &  _Abs_time  )

inline

        {   // wait until time point
        return (wait_for(_Lck, _Abs_time - _Clock::now()));
        }

template<class _Lock , class _Clock , class _Duration , class _Predicate >

bool condition_variable_any::wait_until ( _Lock &  _Lck, const chrono::time_point< _Clock, _Duration > &  _Abs_time, _Predicate  _Pred  )

inline

        {   // wait for signal with timeout and check predicate
        while (!_Pred())
            if (wait_until(_Lck, _Abs_time) == cv_status::timeout)
                return (_Pred());
        return (true);
        }

template<class _Mutex >

_Cv_status condition_variable_any::wait_until ( _Mutex &  _Xtrnl, const xtime *  _Abs_time  )

inline

        {   // wait for signal with timeout
        int _Res;

            {
            shared_ptr<mutex> _Ptr = _Myptr;    // for immunity to *this destruction
            lock_guard<mutex> _Lck(*_Ptr);
            _Xtrnl.unlock(); // could throw
            _Res = _Cnd_timedwaitX(_Mycnd(), _Ptr->_Mymtx(), _Abs_time);
            }   // unlock

        _Relock(_Xtrnl);
        return (_Res == _Thrd_timedout
            ? cv_status::timeout : cv_status::no_timeout);
        }

template<class _Mutex , class _Predicate >

bool condition_variable_any::wait_until ( _Mutex &  _Xtrnl, const xtime *  _Abs_time, _Predicate  _Pred  )

inline

        {   // wait for signal with timeout and check predicate
        while (!_Pred())
            if (wait_until(_Xtrnl, _Abs_time) == cv_status::timeout)
                return (_Pred());
        return (true);
        }

Member Data Documentation

aligned_storage<_Cnd_internal_imp_size, _Cnd_internal_imp_alignment>::type condition_variable_any::_Cnd_storage

private

shared_ptr<mutex> condition_variable_any::_Myptr

private

---

The documentation for this class was generated from the following file:

• VS2017/inc/condition_variable