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

A std::deque wrapper which allows multiple read and write threads to concurrently access it along with providing read threads the ability to wait for the deque to become populated. More...

#include <basic_csv_parser.hpp>

Public Member Functions
	ThreadSafeDeque (size_t notify_size=100)
	ThreadSafeDeque (const ThreadSafeDeque &other)
	ThreadSafeDeque (const std::deque< T > &source)
void	clear () noexcept
bool	empty () const noexcept
T &	front () noexcept
T &	operator[] (size_t n)
void	push_back (T &&item)
T	pop_front () noexcept
size_t	size () const noexcept
constexpr bool	is_waitable () const noexcept
	Returns true if a thread is actively pushing items to this deque.
void	wait ()
	Wait for an item to become available.
std::deque< T >::iterator	begin () noexcept
std::deque< T >::iterator	end () noexcept
void	notify_all ()
	Tell listeners that this deque is actively being pushed to.
void	kill_all ()
	Tell all listeners to stop.

Detailed Description

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

A std::deque wrapper which allows multiple read and write threads to concurrently access it along with providing read threads the ability to wait for the deque to become populated.

Definition at line 94 of file basic_csv_parser.hpp.

---

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

• include/internal/basic_csv_parser.hpp