org.tio.core.task

Class SendRunnable

java.lang.Object

org.tio.utils.thread.pool.AbstractSynRunnable

org.tio.utils.thread.pool.AbstractQueueRunnable<Packet>

org.tio.core.task.SendRunnable

All Implemented Interfaces:

Runnable

public class SendRunnable
extends AbstractQueueRunnable<Packet>

Author:

tanyaowu 2017年4月4日 上午9:19:18

Field Summary

Fields

Modifier and Type	Field and Description
boolean	canSend

Fields inherited from class org.tio.utils.thread.pool.AbstractSynRunnable

executed, executor, runningLock

Constructor Summary

Constructors

Constructor and Description
SendRunnable(ChannelContext channelContext, Executor executor)

Method Summary

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()

Methods inherited from class org.tio.utils.thread.pool.AbstractQueueRunnable

isNeededExecute

Methods inherited from class org.tio.utils.thread.pool.AbstractSynRunnable

execute, isCanceled, run, setCanceled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

canSend

public boolean canSend

Constructor Detail

SendRunnable

public SendRunnable(ChannelContext channelContext,
                    Executor executor)

Parameters:

channelContext -

executor -

Method Detail

getForSendAfterSslHandshakeCompleted

public ConcurrentLinkedQueue<Packet> getForSendAfterSslHandshakeCompleted(boolean forceCreate)

addMsg

public boolean addMsg(Packet packet)

Overrides:

addMsg in class AbstractQueueRunnable<Packet>

Returns:

clearMsgQueue

public void clearMsgQueue()

清空消息队列

Overrides:

clearMsgQueue in class AbstractQueueRunnable<Packet>

runTask

public void runTask()

Specified by:

runTask in class AbstractSynRunnable

sendPacket

public boolean sendPacket(Packet packet)

sendByteBuffer

public void sendByteBuffer(ByteBuffer byteBuffer,
                           Object packets)

Parameters:

byteBuffer -

packets - Packet or List

toString

public String toString()

Overrides:

toString in class Object

logstr

public String logstr()

Overrides:

logstr in class AbstractSynRunnable

Returns:

getMsgQueue

public FullWaitQueue<Packet> getMsgQueue()

Description copied from class: AbstractQueueRunnable

获取消息队列

Specified by:

getMsgQueue in class AbstractQueueRunnable<Packet>

Returns: