Queue with bounded capacity. Will throw exception if capacity does not recede prior to wait time. More...
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... | |
Queue with bounded capacity. Will throw exception if capacity does not recede prior to wait time.
|
inline |
|
inline |
|
inline |
Remove all actions and execute.
|
inline |
Execute actions until stopped.
Implements ExitGames.Concurrency.Core.IQueue.
|
inline |
Stop consuming actions.
Implements ExitGames.Concurrency.Core.IQueue.
|
getset |
Max number of actions to be queued.
|
getset |
Max time to wait for space in the queue.