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