RangersCollectorQueue (datarangers-server-sdk-core 1.4.5-release API)

java.lang.Object
- com.datarangers.asynccollector.RangersCollectorQueue

所有已实现的接口:: CollectorQueue

public class RangersCollectorQueue
extends Object
implements CollectorQueue

作者:: hezhiwei.alden@bytedance.com

方法概要

所有方法静态方法实例方法具体方法
修饰符和类型	方法	说明
`static CollectorQueue`	`getInstance(int queueLength)`
`static CollectorQueue`	`getInstance(CollectorQueue _queue)`
`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