public class BatchBlockingQueue extends AbstractQueue<Batch> implements BlockingQueue<Batch>
Constructor and Description |
---|
BatchBlockingQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
int |
drainTo(Collection<? super Batch> c) |
int |
drainTo(Collection<? super Batch> c,
int n) |
Iterator<Batch> |
iterator() |
boolean |
offer(Batch e) |
boolean |
offer(Batch e,
long timeout,
TimeUnit unit) |
Batch |
peek() |
Batch |
poll() |
Batch |
poll(long timeout,
TimeUnit unit) |
void |
put(Batch e) |
int |
remainingCapacity() |
boolean |
remove(Object o) |
int |
size() |
Batch |
take() |
contains, containsAll, isEmpty, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, contains
addAll, clear, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray
public boolean remove(Object o)
remove
in interface Collection<Batch>
remove
in interface BlockingQueue<Batch>
remove
in class AbstractCollection<Batch>
public Iterator<Batch> iterator()
iterator
in interface Iterable<Batch>
iterator
in interface Collection<Batch>
iterator
in class AbstractCollection<Batch>
public int size()
size
in interface Collection<Batch>
size
in class AbstractCollection<Batch>
public boolean offer(Batch e)
public int drainTo(Collection<? super Batch> c)
drainTo
in interface BlockingQueue<Batch>
public int drainTo(Collection<? super Batch> c, int n)
drainTo
in interface BlockingQueue<Batch>
public boolean offer(Batch e, long timeout, TimeUnit unit) throws InterruptedException
offer
in interface BlockingQueue<Batch>
InterruptedException
public Batch poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue<Batch>
InterruptedException
public void put(Batch e) throws InterruptedException
put
in interface BlockingQueue<Batch>
InterruptedException
public int remainingCapacity()
remainingCapacity
in interface BlockingQueue<Batch>
public Batch take() throws InterruptedException
take
in interface BlockingQueue<Batch>
InterruptedException
Copyright © 2001–2016 Aduna. All rights reserved.