public class SendRunnable extends AbstractQueueRunnable<Packet>
Modifier and Type | Field and Description |
---|---|
boolean |
canSend |
executed, executor, runningLock
Constructor and Description |
---|
SendRunnable(ChannelContext channelContext,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
boolean |
addMsg(Packet packet) |
void |
clearMsgQueue()
清空消息队列
|
ConcurrentLinkedQueue<Packet> |
getForSendAfterSslHandshakeCompleted(boolean forceCreate) |
FullWaitQueue<Packet> |
getMsgQueue()
获取消息队列
|
String |
logstr() |
void |
runTask() |
void |
sendByteBuffer(ByteBuffer byteBuffer,
Object packets) |
boolean |
sendPacket(Packet packet) |
String |
toString() |
isNeededExecute
execute, isCanceled, run, setCanceled
public SendRunnable(ChannelContext channelContext, Executor executor)
channelContext
- executor
- public ConcurrentLinkedQueue<Packet> getForSendAfterSslHandshakeCompleted(boolean forceCreate)
public boolean addMsg(Packet packet)
addMsg
in class AbstractQueueRunnable<Packet>
public void clearMsgQueue()
clearMsgQueue
in class AbstractQueueRunnable<Packet>
public void runTask()
runTask
in class AbstractSynRunnable
public boolean sendPacket(Packet packet)
public void sendByteBuffer(ByteBuffer byteBuffer, Object packets)
byteBuffer
- packets
- Packet or Listpublic String logstr()
logstr
in class AbstractSynRunnable
public FullWaitQueue<Packet> getMsgQueue()
AbstractQueueRunnable
getMsgQueue
in class AbstractQueueRunnable<Packet>
Copyright © 2021. All rights reserved.