|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.dbunit.util.concurrent.LinkedQueue
A linked list based channel implementation. The algorithm avoids contention between puts and takes when the queue is not empty. Normally a put and a take can proceed simultaneously. (Although it does not allow multiple concurrent puts or takes.) This class tends to perform more efficently than other Channel implementations in producer/consumer applications.
[ Introduction to this package. ]
Field Summary | |
protected LinkedNode |
head_
Dummy header node of list. |
protected LinkedNode |
last_
The last node of list. |
protected java.lang.Object |
putLock_
Helper monitor for managing access to last node. |
protected int |
waitingForTake_
The number of threads waiting for a take. |
Constructor Summary | |
LinkedQueue()
|
Method Summary | |
protected java.lang.Object |
extract()
Main mechanics for take/poll |
protected void |
insert(java.lang.Object x)
Main mechanics for put/offer |
boolean |
isEmpty()
|
boolean |
offer(java.lang.Object x,
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 x)
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. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected LinkedNode head_
protected final java.lang.Object putLock_
protected LinkedNode last_
protected int waitingForTake_
Constructor Detail |
public LinkedQueue()
Method Detail |
protected void insert(java.lang.Object x)
protected java.lang.Object extract()
public void put(java.lang.Object x) throws java.lang.InterruptedException
Channel
put
in interface Channel
x
- 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 x, long msecs) throws java.lang.InterruptedException
Channel
offer
in interface Channel
x
- 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
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 peek()
Channel
peek
in interface Channel
public boolean isEmpty()
public java.lang.Object poll(long msecs) throws java.lang.InterruptedException
Channel
poll
in interface Channel
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).
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |