Package org.apache.bookkeeper.common.collections

Interface BatchedBlockingQueue<T>

All Superinterfaces:

BlockingQueue<T>, Collection<T>, Iterable<T>, Queue<T>

All Known Implementing Classes:

BatchedArrayBlockingQueue, BlockingMpscQueue

public interface BatchedBlockingQueue<T>
extends BlockingQueue<T>

Method Summary

Modifier and Type	Method	Description
int	pollAll(T[] array, long timeout, TimeUnit unit)	Removes multiple items from the queue.
void	putAll(T[] a, int offset, int len)
int	takeAll(T[] array)	Drain the queue into an array.

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Queue

element, peek, poll, remove

Method Details

putAll

void putAll(T[] a,
 int offset,
 int len)
     throws InterruptedException

Throws:

InterruptedException

takeAll

int takeAll(T[] array)
     throws InterruptedException

Drain the queue into an array. Wait if there are no items in the queue.

Parameters:

array -

Returns:

Throws:

InterruptedException

pollAll

int pollAll(T[] array,
 long timeout,
 TimeUnit unit)
     throws InterruptedException

Removes multiple items from the queue. The method returns when either: 1. At least one item is available 2. The timeout expires

Parameters:

array -

timeout -

unit -

Returns:

Throws:

InterruptedException