org.d_haven.event
public interface Source
Method Summary | |
---|---|
Object | dequeue()
Dequeues the next element, or null if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
|
Object[] | dequeue(int num)
Dequeues at most num available elements. |
Object[] | dequeueAll()
Dequeues all available elements. |
void | setTimeout(long millis)
Sets the timeout on a blocking Source. |
int | size()
Returns the number of elements waiting in this Source.
|
null
if there is
nothing left on the queue or in case of a timeout while
attempting to obtain the mutex.
Returns: the next queue element on the Source
num
available elements. Returns a
zero-sized array in case of a timeout while attempting to obtain
the mutex or if there is nothing left on the Source.
Parameters: num The maximum number of elements to dequeue
Returns: At most num
elements from the Source
Returns: all pending elements on the Source
1
will force all dequeue
operations to
block for up to that number of milliseconds waiting for new
elements. Values below 1
will turn off blocking for
Source. This is intentional because a Source should never block
indefinitely.
Parameters: millis Number of milliseconds to block
Returns: the number of elements in the Source