public class Signaler
extends java.lang.Object
implements java.io.Closeable
| Modifier and Type | Field and Description |
|---|---|
private java.nio.channels.Pipe.SourceChannel |
r |
private int |
rcursor |
private java.nio.channels.Selector |
selector |
private java.nio.channels.Pipe.SinkChannel |
w |
private java.util.concurrent.atomic.AtomicInteger |
wcursor |
| Constructor and Description |
|---|
Signaler() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
java.nio.channels.SelectableChannel |
getFd() |
void |
recv() |
void |
send() |
boolean |
waitEvent(long timeout) |
private final java.nio.channels.Pipe.SinkChannel w
private final java.nio.channels.Pipe.SourceChannel r
private final java.nio.channels.Selector selector
private final java.util.concurrent.atomic.AtomicInteger wcursor
private int rcursor
public void close()
throws java.io.IOException
close in interface java.io.Closeableclose in interface java.lang.AutoCloseablejava.io.IOExceptionpublic java.nio.channels.SelectableChannel getFd()
public void send()
public boolean waitEvent(long timeout)
public void recv()