Package | Description |
---|---|
com.hazelcast.internal.util.concurrent |
Concurrent queues etc.
|
com.hazelcast.util.collection |
The Agrona project backport: collections.
|
Modifier and Type | Method and Description |
---|---|
int |
ConcurrentConveyor.drain(int queueIndex,
Predicate<? super E> itemHandler)
Drains a batch of items from the queue at the supplied index to the
supplied
itemHandler . |
int |
OneToOneConcurrentArrayQueue.drain(Predicate<? super E> itemHandler) |
int |
Pipe.drain(Predicate<? super E> itemHandler)
Drains the items available in the pipe to the supplied item handler.
|
int |
ManyToOneConcurrentArrayQueue.drain(Predicate<? super E> itemHandler) |
Constructor and Description |
---|
MapDelegatingSet(Map<?,?> delegate,
Supplier<Iterator<V>> iterator,
Predicate contains) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.