csv::internals::SingleThreadDeque< T > Class Template Reference

Minimal row queue used when parser threading is disabled. More...

#include <single_thread_deque.hpp>

Public Member Functions
	SingleThreadDeque (size_t notify_size=100)
	SingleThreadDeque (const SingleThreadDeque &other)
	SingleThreadDeque (const std::deque< T > &source)
bool	empty () const noexcept
void	push_back (T &&item)
void	append_rows (std::vector< T > &&rows)
T	pop_front () noexcept
size_t	drain_front (std::vector< T > &out, size_t max_items)
	Move up to max_items rows into a caller-owned batch buffer.
bool	is_waitable () const noexcept
void	wait ()
size_t	size () const noexcept
void	notify_all ()
void	kill_all ()

Detailed Description

template<typename T>
class csv::internals::SingleThreadDeque< T >

Minimal row queue used when parser threading is disabled.

This intentionally stores rows directly. It only needs to satisfy the parser queue operations in RowDequeLike; it does not mirror ThreadSafeDeque's batch storage or test-only inspection helper.

Definition at line 22 of file single_thread_deque.hpp.

Constructor & Destructor Documentation

SingleThreadDeque() [1/3]

template<typename T >

csv::internals::SingleThreadDeque< T >::SingleThreadDeque ( size_t  notify_size = 100 )

inline

Definition at line 24 of file single_thread_deque.hpp.

SingleThreadDeque() [2/3]

template<typename T >

csv::internals::SingleThreadDeque< T >::SingleThreadDeque ( const SingleThreadDeque< T > &  other )

inline

Definition at line 28 of file single_thread_deque.hpp.

SingleThreadDeque() [3/3]

template<typename T >

csv::internals::SingleThreadDeque< T >::SingleThreadDeque ( const std::deque< T > &  source )

inline

Definition at line 34 of file single_thread_deque.hpp.

Member Function Documentation

append_rows()

template<typename T >

void csv::internals::SingleThreadDeque< T >::append_rows ( std::vector< T > &&  rows )

inline

Definition at line 47 of file single_thread_deque.hpp.

drain_front()

template<typename T >

size_t csv::internals::SingleThreadDeque< T >::drain_front ( std::vector< T > &  out, size_t  max_items  )

inline

Move up to max_items rows into a caller-owned batch buffer.

Definition at line 72 of file single_thread_deque.hpp.

empty()

template<typename T >

bool csv::internals::SingleThreadDeque< T >::empty ( ) const

inlinenoexcept

Definition at line 38 of file single_thread_deque.hpp.

is_waitable()

template<typename T >

bool csv::internals::SingleThreadDeque< T >::is_waitable ( ) const

inlinenoexcept

Definition at line 88 of file single_thread_deque.hpp.

kill_all()

template<typename T >

void csv::internals::SingleThreadDeque< T >::kill_all ( )

inline

Definition at line 104 of file single_thread_deque.hpp.

notify_all()

template<typename T >

void csv::internals::SingleThreadDeque< T >::notify_all ( )

inline

Definition at line 100 of file single_thread_deque.hpp.

pop_front()

template<typename T >

T csv::internals::SingleThreadDeque< T >::pop_front ( )

inlinenoexcept

Definition at line 60 of file single_thread_deque.hpp.

push_back()

template<typename T >

void csv::internals::SingleThreadDeque< T >::push_back ( T &&  item )

inline

Definition at line 42 of file single_thread_deque.hpp.

size()

template<typename T >

size_t csv::internals::SingleThreadDeque< T >::size ( ) const

inlinenoexcept

Definition at line 96 of file single_thread_deque.hpp.

wait()

template<typename T >

void csv::internals::SingleThreadDeque< T >::wait ( )

inline

Definition at line 92 of file single_thread_deque.hpp.

---

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

• include/internal/single_thread_deque.hpp