org.tio.utils.queue

Class TioFullWaitQueue<T>

java.lang.Object

org.tio.utils.queue.TioFullWaitQueue<T>

All Implemented Interfaces:

FullWaitQueue<T>

public class TioFullWaitQueue<T>
extends Object
implements FullWaitQueue<T>

暂时用ConcurrentLinkedQueue代替

Author:

tanyaowu 2019年9月30日 上午9:22:00

Constructor Summary

Constructors

Constructor and Description
TioFullWaitQueue(Integer capacity, boolean useSingleProducer)

Method Summary

Modifier and Type	Method and Description
boolean	add(T e) write 向队列尾添加一个元素，如果队列已经满了，则等待一段时间
void	clear()
boolean	isEmpty()
T	poll() read Retrieves and removes the head of this queue, or returns null if this queue is empty.
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

TioFullWaitQueue

public TioFullWaitQueue(Integer capacity,
                        boolean useSingleProducer)

Parameters:

capacity -

useSingleProducer -

Method Detail

add

public boolean add(T e)

Description copied from interface: FullWaitQueue

write 向队列尾添加一个元素，如果队列已经满了，则等待一段时间

Specified by:

add in interface FullWaitQueue<T>

Returns:

poll

public T poll()

Description copied from interface: FullWaitQueue

read Retrieves and removes the head of this queue, or returns null if this queue is empty.

Specified by:

poll in interface FullWaitQueue<T>

Returns:

the head of this queue, or null if this queue is empty

size

public int size()

Specified by:

size in interface FullWaitQueue<T>

clear

public void clear()

Specified by:

clear in interface FullWaitQueue<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface FullWaitQueue<T>

Returns: