protected class TCPConnectionMap.TCPConnection.Sender
extends java.lang.Object
implements java.lang.Runnable
限定符和类型 | 字段和说明 |
---|---|
protected java.lang.Thread |
runner |
protected java.util.concurrent.BlockingQueue<byte[]> |
send_queue |
protected boolean |
started |
构造器和说明 |
---|
TCPConnectionMap.TCPConnection.Sender(ThreadFactory tf,
int send_queue_size) |
限定符和类型 | 方法和说明 |
---|---|
void |
addToQueue(byte[] data) |
boolean |
canRun() |
boolean |
isRunning() |
void |
run() |
TCPConnectionMap.TCPConnection.Sender |
start() |
TCPConnectionMap.TCPConnection.Sender |
stop() |
protected final java.util.concurrent.BlockingQueue<byte[]> send_queue
protected final java.lang.Thread runner
protected volatile boolean started
public TCPConnectionMap.TCPConnection.Sender(ThreadFactory tf, int send_queue_size)
public void addToQueue(byte[] data) throws java.lang.Exception
java.lang.Exception
public TCPConnectionMap.TCPConnection.Sender start()
public TCPConnectionMap.TCPConnection.Sender stop()
public boolean isRunning()
public boolean canRun()
public void run()
run
在接口中 java.lang.Runnable