public class IndexQueue extends AbstractQueue<org.infinispan.persistence.sifs.IndexRequest> implements BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
Constructor and Description |
---|
IndexQueue(int segments,
int capacity,
Equivalence<Object> keyEquivalence) |
Modifier and Type | Method and Description |
---|---|
int |
drainTo(Collection<? super org.infinispan.persistence.sifs.IndexRequest> c) |
int |
drainTo(Collection<? super org.infinispan.persistence.sifs.IndexRequest> c,
int maxElements) |
Iterator<org.infinispan.persistence.sifs.IndexRequest> |
iterator() |
boolean |
offer(org.infinispan.persistence.sifs.IndexRequest indexRequest) |
boolean |
offer(org.infinispan.persistence.sifs.IndexRequest indexRequest,
long timeout,
TimeUnit unit) |
org.infinispan.persistence.sifs.IndexRequest |
peek() |
org.infinispan.persistence.sifs.IndexRequest |
poll() |
org.infinispan.persistence.sifs.IndexRequest |
poll(long timeout,
TimeUnit unit) |
void |
put(org.infinispan.persistence.sifs.IndexRequest indexRequest) |
int |
remainingCapacity() |
int |
size() |
BlockingQueue<org.infinispan.persistence.sifs.IndexRequest> |
subQueue(int id) |
org.infinispan.persistence.sifs.IndexRequest |
take() |
contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, contains, remove
addAll, clear, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray
public IndexQueue(int segments, int capacity, Equivalence<Object> keyEquivalence)
public Iterator<org.infinispan.persistence.sifs.IndexRequest> iterator()
iterator
in interface Iterable<org.infinispan.persistence.sifs.IndexRequest>
iterator
in interface Collection<org.infinispan.persistence.sifs.IndexRequest>
iterator
in class AbstractCollection<org.infinispan.persistence.sifs.IndexRequest>
public int size()
size
in interface Collection<org.infinispan.persistence.sifs.IndexRequest>
size
in class AbstractCollection<org.infinispan.persistence.sifs.IndexRequest>
public void put(org.infinispan.persistence.sifs.IndexRequest indexRequest) throws InterruptedException
put
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
InterruptedException
public boolean offer(org.infinispan.persistence.sifs.IndexRequest indexRequest, long timeout, TimeUnit unit) throws InterruptedException
offer
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
InterruptedException
public org.infinispan.persistence.sifs.IndexRequest take() throws InterruptedException
take
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
InterruptedException
public org.infinispan.persistence.sifs.IndexRequest poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
InterruptedException
public int remainingCapacity()
remainingCapacity
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
public int drainTo(Collection<? super org.infinispan.persistence.sifs.IndexRequest> c)
drainTo
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
public int drainTo(Collection<? super org.infinispan.persistence.sifs.IndexRequest> c, int maxElements)
drainTo
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
public boolean offer(org.infinispan.persistence.sifs.IndexRequest indexRequest)
offer
in interface BlockingQueue<org.infinispan.persistence.sifs.IndexRequest>
offer
in interface Queue<org.infinispan.persistence.sifs.IndexRequest>
public org.infinispan.persistence.sifs.IndexRequest poll()
public org.infinispan.persistence.sifs.IndexRequest peek()
public BlockingQueue<org.infinispan.persistence.sifs.IndexRequest> subQueue(int id)
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.