Class AbstractNioChannel.WriteRequestQueue
- java.lang.Object
-
- org.jboss.netty.channel.socket.nio.AbstractNioChannel.WriteRequestQueue
-
- Enclosing class:
- AbstractNioChannel<C extends java.nio.channels.SelectableChannel & java.nio.channels.WritableByteChannel>
final class AbstractNioChannel.WriteRequestQueue extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private ThreadLocalBoolean
notifying
private java.util.Queue<MessageEvent>
queue
-
Constructor Summary
Constructors Constructor Description WriteRequestQueue()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private int
getMessageSize(MessageEvent e)
boolean
isEmpty()
boolean
offer(MessageEvent e)
MessageEvent
poll()
-
-
-
Field Detail
-
notifying
private final ThreadLocalBoolean notifying
-
queue
private final java.util.Queue<MessageEvent> queue
-
-
Method Detail
-
isEmpty
public boolean isEmpty()
-
offer
public boolean offer(MessageEvent e)
-
poll
public MessageEvent poll()
-
getMessageSize
private int getMessageSize(MessageEvent e)
-
-