Synchronized_queue< T, Container > Class Template Reference

Inheritance diagram for Synchronized_queue< T, Container >:

Collaboration diagram for Synchronized_queue< T, Container >:

Public Member Functions
void	push (T &&v)
optional< reference_wrapper< T > >	pull ()

Public Attributes
condition_variable	cv
bool	stop = false

Detailed Description

template<typename T, class Container = std::queue<T>>
class Synchronized_queue< T, Container >

Definition at line 726 of file patterns.cpp.

Member Function Documentation

pull()

template<typename T , class Container = std::queue<T>>

optional< reference_wrapper< T > > Synchronized_queue< T, Container >::pull ( )

inline

Definition at line 738 of file patterns.cpp.

                                          {
        unique_lock<mutex> lk(mtx);
        cv.wait(lk, [&] { return !this->empty() || stop; });
        optional<reference_wrapper<T>> ret;
        if (stop) {
            ret =  nullopt;
        } else {
            ret = make_optional(ref(Container::front()));
            this->pop();
        }
        return ret;
    };

push()

template<typename T , class Container = std::queue<T>>

void Synchronized_queue< T, Container >::push ( T &&  v )

inline

Definition at line 733 of file patterns.cpp.

                     {
        scoped_lock<mutex>{mtx}, Container::push(v);
        cv.notify_one();
    };

Member Data Documentation

cv

template<typename T , class Container = std::queue<T>>

condition_variable Synchronized_queue< T, Container >::cv

Definition at line 731 of file patterns.cpp.

stop

template<typename T , class Container = std::queue<T>>

bool Synchronized_queue< T, Container >::stop = false

Definition at line 732 of file patterns.cpp.

---

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

• patterns.cpp