A dispatch queue. More...
Public Member Functions | |
void | destroy () |
Destroys the queue. More... | |
DispatchQueue (fm.liveswitch.IAction1< T > action) | |
Initializes a new instance of the fm.liveswitch.DispatchQueue class. More... | |
DispatchQueue (fm.liveswitch.IFunction1< T, fm.liveswitch.Future< Object >> func) | |
Initializes a new instance of the fm.liveswitch.DispatchQueue class. More... | |
void | enqueue (T item) |
Enqueues an item for processing. More... | |
long | getQueueCount () |
Gets the number of items in the queue. More... | |
void | waitForDrain () |
Blocks until the queue is empty. More... | |
A dispatch queue.
fm.liveswitch.DispatchQueue< T >.DispatchQueue | ( | fm.liveswitch.IAction1< T > | action | ) |
Initializes a new instance of the fm.liveswitch.DispatchQueue class.
action | The processing action. |
fm.liveswitch.DispatchQueue< T >.DispatchQueue | ( | fm.liveswitch.IFunction1< T, fm.liveswitch.Future< Object >> | func | ) |
Initializes a new instance of the fm.liveswitch.DispatchQueue class.
func | The processing function. |
void fm.liveswitch.DispatchQueue< T >.destroy | ( | ) |
Destroys the queue.
Implements fm.liveswitch.IDispatchQueue< T >.
void fm.liveswitch.DispatchQueue< T >.enqueue | ( | T | item | ) |
Enqueues an item for processing.
item | The item. |
Implements fm.liveswitch.IDispatchQueue< T >.
long fm.liveswitch.DispatchQueue< T >.getQueueCount | ( | ) |
Gets the number of items in the queue.
Implements fm.liveswitch.IDispatchQueue< T >.
void fm.liveswitch.DispatchQueue< T >.waitForDrain | ( | ) |
Blocks until the queue is empty.