protected class NioConnection.Reader extends Object implements Runnable, Closeable
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 |
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 isRunning()
public void receive()
protected void _run()
protected void register(int op)
protected void clear(int op)
protected void state(NioConnection.State st)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.