Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.locks.Condition |
condition |
private YPipe<Command> |
cpipe |
private Errno |
errno |
private java.lang.String |
name |
private java.util.ArrayList<Signaler> |
signalers |
private java.util.concurrent.locks.ReentrantLock |
sync |
Constructor and Description |
---|
MailboxSafe(Ctx ctx,
java.util.concurrent.locks.ReentrantLock sync,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
addSignaler(Signaler signaler) |
void |
clearSignalers() |
void |
close() |
Command |
recv(long timeout) |
void |
removeSignaler(Signaler signaler) |
void |
send(Command cmd) |
java.lang.String |
toString() |
private final java.util.concurrent.locks.ReentrantLock sync
private final java.util.concurrent.locks.Condition condition
private final java.util.ArrayList<Signaler> signalers
private final java.lang.String name
private final Errno errno
public MailboxSafe(Ctx ctx, java.util.concurrent.locks.ReentrantLock sync, java.lang.String name)
public void addSignaler(Signaler signaler)
public void removeSignaler(Signaler signaler)
public void clearSignalers()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object