#include <queue_task.h>

Collaboration diagram for WorkQueue< QueueEntryT >:

Public Types
typedef tbb::concurrent_queue < QueueEntryT >	Queue

typedef boost::function< bool(QueueEntryT)>	Callback

typedef boost::function< bool(void)>	StartRunnerFunc

typedef boost::function< void(bool)>	TaskExitCallback

typedef boost::function< bool()>	TaskEntryCallback

Public Member Functions
	WorkQueue (int taskId, int taskInstance, Callback callback, size_t size=kMaxSize, size_t max_iterations=kMaxIterations)

void	Shutdown (bool delete_entries=true)

void	ScheduleShutdown (bool delete_entries=true)

	~WorkQueue ()

void	SetStartRunnerFunc (StartRunnerFunc start_runner_fn)

void	SetSize (size_t size)

void	SetBounded (bool bounded)

bool	GetBounded () const

void	SetHighWaterMark (const WaterMarkInfos &high_water)

void	SetHighWaterMark (const WaterMarkInfo &hwm_info)

void	ResetHighWaterMark ()

WaterMarkInfos	GetHighWaterMark () const

void	SetLowWaterMark (const WaterMarkInfos &low_water)

void	SetLowWaterMark (const WaterMarkInfo &lwm_info)

void	ResetLowWaterMark ()

WaterMarkInfos	GetLowWaterMark () const

bool	Enqueue (QueueEntryT entry)

bool	Dequeue (QueueEntryT *entry)

int	GetTaskId () const

int	GetTaskInstance () const

void	MayBeStartRunner ()

Callback	GetCallback () const

void	SetEntryCallback (TaskEntryCallback on_entry)

void	SetExitCallback (TaskExitCallback on_exit)

void	set_name (const std::string &name)

std::string	Description () const

void	set_disable (bool disabled)

bool	IsDisabled () const

size_t	on_entry_defer_count () const

bool	OnEntry ()

void	OnExit (bool done)

bool	IsQueueEmpty () const

size_t	Length () const

size_t	NumEnqueues () const

size_t	NumDequeues () const

size_t	NumDrops () const

bool	deleted () const

uint32_t	task_starts () const

size_t	max_queue_len () const

bool	measure_busy_time () const

void	set_measure_busy_time (bool val) const

uint64_t	busy_time () const

void	add_busy_time (uint64_t t)

void	ClearStats () const

Static Public Attributes
static const int	kMaxSize = 1024

static const int	kMaxIterations = 32

Private Member Functions
bool	DequeueInternal (QueueEntryT *entry)

bool	DequeueInternalLocked (QueueEntryT *entry)

bool	AreWaterMarksSet () const

void	ShutdownLocked (bool delete_entries)

size_t	AtomicIncrementQueueCount (QueueEntryT *entry)

size_t	AtomicDecrementQueueCount (QueueEntryT *entry)

void	ProcessHighWaterMarks (size_t count)

void	ProcessLowWaterMarks (size_t count)

bool	EnqueueInternal (QueueEntryT entry)

bool	EnqueueInternalLocked (QueueEntryT entry)

bool	EnqueueBounded (QueueEntryT entry)

bool	EnqueueBoundedLocked (QueueEntryT entry)

bool	RunnerAbortLocked ()

bool	RunnerAbort ()

bool	RunnerDone ()

	DISALLOW_COPY_AND_ASSIGN (WorkQueue)

Private Attributes
Queue	queue_

tbb::atomic< size_t >	count_

tbb::mutex	mutex_

bool	running_

int	taskId_

int	taskInstance_

std::string	name_

Callback	callback_

TaskEntryCallback	on_entry_cb_

TaskExitCallback	on_exit_cb_

StartRunnerFunc	start_runner_

QueueTaskRunner< QueueEntryT, WorkQueue< QueueEntryT > > *	current_runner_

size_t	on_entry_defer_count_

tbb::atomic< bool >	disabled_

bool	deleted_

size_t	enqueues_

size_t	dequeues_

size_t	drops_

size_t	max_iterations_

size_t	size_

bool	bounded_

bool	shutdown_scheduled_

bool	delete_entries_on_shutdown_

WaterMarkTuple	watermarks_

tbb::mutex	water_mutex_

uint32_t	task_starts_

size_t	max_queue_len_

uint64_t	busy_time_

bool	measure_busy_time_

Friends
class	QueueTaskTest

class	QueueTaskShutdownTest

class	QueueTaskWaterMarkTest

class	QueueTaskRunner< QueueEntryT, WorkQueue< QueueEntryT > >