EDU.oswego.cs.dl.util.concurrent.misc
public class FIFOSlot extends java.lang.Object implements BoundedChannel
Constructor and Description |
---|
FIFOSlot() |
Modifier and Type | Method and Description |
---|---|
int |
capacity()
Return the maximum number of elements that can be held.
|
boolean |
offer(java.lang.Object item,
long msecs)
Place item in channel only if it can be accepted within
msecs milliseconds.
|
java.lang.Object |
peek()
Return, but do not remove object at head of Channel,
or null if it is empty.
|
java.lang.Object |
poll(long msecs)
Return and remove an item from channel only if one is available within
msecs milliseconds.
|
void |
put(java.lang.Object item)
Place item in the channel, possibly waiting indefinitely until
it can be accepted.
|
java.lang.Object |
take()
Return and remove an item from channel,
possibly waiting indefinitely until
such an item exists.
|
public void put(java.lang.Object item) throws java.lang.InterruptedException
Channel
put
in interface Channel
put
in interface Puttable
item
- the element to be inserted. Should be non-null.java.lang.InterruptedException
- if the current thread has
been interrupted at a point at which interruption
is detected, in which case the element is guaranteed not
to be inserted. Otherwise, on normal return, the element is guaranteed
to have been inserted.public boolean offer(java.lang.Object item, long msecs) throws java.lang.InterruptedException
Channel
offer
in interface Channel
offer
in interface Puttable
item
- the element to be inserted. Should be non-null.msecs
- the number of milliseconds to wait. If less than
or equal to zero, the method does not perform any timed waits,
but might still require
access to a synchronization lock, which can impose unbounded
delay if there is a lot of contention for the channel.java.lang.InterruptedException
- if the current thread has
been interrupted at a point at which interruption
is detected, in which case the element is guaranteed not
to be inserted (i.e., is equivalent to a false return).public java.lang.Object take() throws java.lang.InterruptedException
Channel
take
in interface Channel
take
in interface Takable
java.lang.InterruptedException
- if the current thread has
been interrupted at a point at which interruption
is detected, in which case state of the channel is unchanged.public java.lang.Object poll(long msecs) throws java.lang.InterruptedException
Channel
poll
in interface Channel
poll
in interface Takable
msecs
- the number of milliseconds to wait. If less than
or equal to zero, the operation does not perform any timed waits,
but might still require
access to a synchronization lock, which can impose unbounded
delay if there is a lot of contention for the channel.java.lang.InterruptedException
- if the current thread has
been interrupted at a point at which interruption
is detected, in which case state of the channel is unchanged
(i.e., equivalent to a null return).public int capacity()
BoundedChannel
capacity
in interface BoundedChannel