protected class NioConnection.Reader extends Object implements Runnable, Closeable, Condition
Modifier and Type | Field and Description |
---|---|
protected boolean |
data_available |
protected CondVar |
data_available_cond |
protected Lock |
lock |
protected boolean |
running |
protected NioConnection.State |
state |
protected Thread |
thread |
Modifier | Constructor and Description |
---|---|
protected |
Reader() |
Modifier and Type | Method and Description |
---|---|
protected void |
_run() |
protected void |
clear(int op) |
void |
close() |
boolean |
isMet()
Return true if the condition is met and false otherwise
|
boolean |
isRunning() |
void |
receive()
Called by the selector when data is ready to be read from the SocketChannel
|
protected void |
register(int op) |
void |
run() |
protected void |
start() |
protected void |
state(NioConnection.State st) |
protected void |
stop() |
protected final Lock lock
protected NioConnection.State state
protected volatile boolean data_available
protected final CondVar data_available_cond
protected volatile Thread thread
protected volatile boolean running
protected void start()
protected void stop()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public boolean isMet()
Condition
public boolean isRunning()
public void receive()
protected void _run()
protected void register(int op)
protected void clear(int op)
protected void state(NioConnection.State st)
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.