ExitGames.Concurrency.Core.BoundedQueue Class Reference

Queue with bounded capacity. Will throw exception if capacity does not recede prior to wait time. More...

Inheritance diagram for ExitGames.Concurrency.Core.BoundedQueue:

Public Member Functions
	BoundedQueue ()
void	Enqueue (IFiberAction action)
	Enqueue action. More...
void	Run ()
	Execute actions until stopped. More...
void	Stop ()
	Stop consuming actions. More...
bool	ExecuteNextBatch ()
	Remove all actions and execute. More...

Properties
int	MaxDepth [get, set]
	Max number of actions to be queued. More...
int	MaxEnqueueWaitTime [get, set]
	Max time to wait for space in the queue. More...

Detailed Description

Queue with bounded capacity. Will throw exception if capacity does not recede prior to wait time.

Constructor & Destructor Documentation

BoundedQueue()

ExitGames.Concurrency.Core.BoundedQueue.BoundedQueue ( )

inline

Member Function Documentation

Enqueue()

void ExitGames.Concurrency.Core.BoundedQueue.Enqueue ( IFiberAction  action )

inline

Enqueue action.

Parameters

action

Implements ExitGames.Concurrency.Core.IQueue.

ExecuteNextBatch()

bool ExitGames.Concurrency.Core.BoundedQueue.ExecuteNextBatch ( )

inline

Remove all actions and execute.

Returns

Run()

void ExitGames.Concurrency.Core.BoundedQueue.Run ( )

inline

Execute actions until stopped.

Implements ExitGames.Concurrency.Core.IQueue.

Stop()

void ExitGames.Concurrency.Core.BoundedQueue.Stop ( )

inline

Stop consuming actions.

Implements ExitGames.Concurrency.Core.IQueue.

Property Documentation

MaxDepth

int ExitGames.Concurrency.Core.BoundedQueue.MaxDepth

getset

Max number of actions to be queued.

MaxEnqueueWaitTime

int ExitGames.Concurrency.Core.BoundedQueue.MaxEnqueueWaitTime

getset

Max time to wait for space in the queue.