Modifier and Type | Field and Description |
---|---|
private boolean |
active |
private YPipe<Command> |
cpipe |
private Errno |
errno |
private java.lang.String |
name |
private Signaler |
signaler |
private java.util.concurrent.locks.Lock |
sync |
Constructor and Description |
---|
Mailbox(Ctx ctx,
java.lang.String name,
int tid) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.nio.channels.SelectableChannel |
getFd() |
Command |
recv(long timeout) |
void |
send(Command cmd) |
java.lang.String |
toString() |
private final Signaler signaler
private final java.util.concurrent.locks.Lock sync
private boolean active
private final java.lang.String name
private final Errno errno
public Mailbox(Ctx ctx, java.lang.String name, int tid)
public java.nio.channels.SelectableChannel getFd()
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