protected class TcpConnection.Sender extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
protected Thread |
runner |
protected BlockingQueue<Buffer> |
send_queue |
protected boolean |
started |
Constructor and Description |
---|
Sender(ThreadFactory tf,
int send_queue_size) |
Modifier and Type | Method and Description |
---|---|
void |
addToQueue(Buffer data) |
boolean |
canRun() |
boolean |
isRunning() |
void |
run() |
TcpConnection.Sender |
start() |
TcpConnection.Sender |
stop() |
protected final BlockingQueue<Buffer> send_queue
protected final Thread runner
protected volatile boolean started
public Sender(ThreadFactory tf, int send_queue_size)
public TcpConnection.Sender start()
public TcpConnection.Sender stop()
public boolean isRunning()
public boolean canRun()
Copyright © 2019 JBoss, a division of Red Hat. All rights reserved.