|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectautohit.common.channels.QueuedDrain
Basically, a queued drain. It is absolutely threadsafe. It can be used for interprocess communication.
EPG - Rewrite - 17Sep03
Constructor Summary | |
QueuedDrain()
Constructor |
Method Summary | |
Atom |
block()
Block until there is something in the queue. |
Atom |
get()
Get something from the queue. |
void |
init(java.lang.String name)
Initializer |
boolean |
poll()
Is there something available. |
Receipt |
post(Atom a)
Post an item |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public QueuedDrain()
Method Detail |
public void init(java.lang.String name) throws ChannelException
name
- of the drain
ChannelException
public Receipt post(Atom a) throws ChannelException
post
in interface Drain
a
- An atom containing the posted data
ChannelException
public boolean poll()
public Atom get() throws ChannelException
ChannelException
Atom
public Atom block() throws ChannelException
ChannelException
Atom
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |