proxygen: folly::UnboundedBlockingQueue< T

#include <UnboundedBlockingQueue.h>

Inheritance diagram for folly::UnboundedBlockingQueue< T >:

Public Member Functions
virtual	~UnboundedBlockingQueue ()

BlockingQueueAddResult	add (T item) override

T	take () override

folly::Optional< T >	try_take_for (std::chrono::milliseconds time) override

size_t	size () override

Public Member Functions inherited from folly::BlockingQueue< T >
virtual	~BlockingQueue ()=default

virtual BlockingQueueAddResult	addWithPriority (T item, int8_t)

virtual uint8_t	getNumPriorities ()

Private Attributes
LifoSem	sem_

UMPMCQueue< T, false, 6 >	queue_

Detailed Description

template<class T>
class folly::UnboundedBlockingQueue< T >

Definition at line 26 of file UnboundedBlockingQueue.h.

Constructor & Destructor Documentation

template<class T>

virtual folly::UnboundedBlockingQueue< T >::~UnboundedBlockingQueue ( )

inlinevirtual

Definition at line 28 of file UnboundedBlockingQueue.h.

28 {}

Member Function Documentation

template<class T>

BlockingQueueAddResult folly::UnboundedBlockingQueue< T >::add ( T item )

inlineoverridevirtual

Implements folly::BlockingQueue< T >.

Definition at line 30 of file UnboundedBlockingQueue.h.

References folly::gen::move, folly::detail::LifoSemBase< Handoff, Atom >::post(), folly::UnboundedBlockingQueue< T >::queue_, and folly::UnboundedBlockingQueue< T >::sem_.

Referenced by TEST().

                                               {
     queue_.enqueue(std::move(item));
     return sem_.post();
   }

template<class T>

size_t folly::UnboundedBlockingQueue< T >::size ( )

inlineoverridevirtual

Implements folly::BlockingQueue< T >.

Definition at line 53 of file UnboundedBlockingQueue.h.

References folly::UnboundedBlockingQueue< T >::queue_.

Referenced by TEST().

                          {
     return queue_.size();
   }

template<class T>

T folly::UnboundedBlockingQueue< T >::take ( )

inlineoverridevirtual

Implements folly::BlockingQueue< T >.

Definition at line 35 of file UnboundedBlockingQueue.h.

References folly::UnboundedBlockingQueue< T >::queue_, folly::UnboundedBlockingQueue< T >::sem_, folly::T, and folly::detail::LifoSemBase< Handoff, Atom >::wait().

Referenced by TEST().

                     {
     T item;
     while (!queue_.try_dequeue(item)) {
       sem_.wait();
     }
     return item;
   }

template<class T>

folly::Optional<T> folly::UnboundedBlockingQueue< T >::try_take_for ( std::chrono::milliseconds time )

inlineoverridevirtual

Implements folly::BlockingQueue< T >.

Definition at line 43 of file UnboundedBlockingQueue.h.

References folly::gen::move, folly::none, folly::UnboundedBlockingQueue< T >::queue_, folly::UnboundedBlockingQueue< T >::sem_, folly::T, and folly::detail::LifoSemBase< Handoff, Atom >::try_wait_for().

                                                                      {
     T item;
     while (!queue_.try_dequeue(item)) {
       if (!sem_.try_wait_for(time)) {
         return folly::none;
       }
     }
     return std::move(item);
   }