com.datarangers.asynccollector

类 RangersCollectorQueue

java.lang.Object

com.datarangers.asynccollector.RangersCollectorQueue

所有已实现的接口:

CollectorQueue

public class RangersCollectorQueue
extends Object
implements CollectorQueue

作者:

hezhiwei.alden@bytedance.com

方法概要

方法

限定符和类型	方法和说明
static CollectorQueue	getInstance(CollectorQueue _queue)
static CollectorQueue	getInstance(int queueLength)
boolean	offer(Message t) 功能描述: 发送一个Message到队列中
List<Message>	poll(int waitTimeMs)
int	size()
List<Message>	take() 功能描述: 从队列里消费一批message，没有过期时间，如果自行设置过期时间则需要在没有数据的时候返回null

从类继承的方法 java.lang.Object

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

方法详细资料

getInstance

public static CollectorQueue getInstance(int queueLength)

getInstance

public static CollectorQueue getInstance(CollectorQueue _queue)

take

public List<Message> take()
                   throws InterruptedException

从接口复制的说明: CollectorQueue

功能描述: 从队列里消费一批message，没有过期时间，如果自行设置过期时间则需要在没有数据的时候返回null

指定者:

take 在接口中 CollectorQueue

抛出:

InterruptedException

poll

public List<Message> poll(int waitTimeMs)
                   throws InterruptedException

指定者:

poll 在接口中 CollectorQueue

抛出:

InterruptedException

offer

public boolean offer(Message t)
              throws InterruptedException

从接口复制的说明: CollectorQueue

功能描述: 发送一个Message到队列中

指定者:

offer 在接口中 CollectorQueue

抛出:

InterruptedException

size

public int size()

指定者:

size 在接口中 CollectorQueue