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
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-2013 Aduna. All Rights Reserved.