public class TaskQueue extends LinkedBlockingQueue<Runnable>
| Constructor and Description |
|---|
TaskQueue() |
TaskQueue(Collection<? extends Runnable> c) |
TaskQueue(int capacity) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
force(Runnable o) |
boolean |
force(Runnable o,
long timeout,
TimeUnit unit) |
boolean |
offer(Runnable o) |
Runnable |
poll(long timeout,
TimeUnit unit) |
int |
remainingCapacity() |
void |
setForcedRemainingCapacity(Integer forcedRemainingCapacity) |
void |
setParent(ThreadPoolExecutor tp) |
Runnable |
take() |
clear, contains, drainTo, drainTo, iterator, offer, peek, poll, put, remove, size, toArray, toArray, toStringadd, addAll, element, removecontainsAll, isEmpty, removeAll, retainAllclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddaddAll, containsAll, equals, hashCode, isEmpty, removeAll, retainAllpublic TaskQueue()
public TaskQueue(int capacity)
public TaskQueue(Collection<? extends Runnable> c)
public void setParent(ThreadPoolExecutor tp)
public boolean force(Runnable o)
public boolean force(Runnable o, long timeout, TimeUnit unit) throws InterruptedException
InterruptedExceptionpublic boolean offer(Runnable o)
offer in interface BlockingQueue<Runnable>offer in interface Queue<Runnable>offer in class LinkedBlockingQueue<Runnable>public Runnable poll(long timeout, TimeUnit unit) throws InterruptedException
poll in interface BlockingQueue<Runnable>poll in class LinkedBlockingQueue<Runnable>InterruptedExceptionpublic Runnable take() throws InterruptedException
take in interface BlockingQueue<Runnable>take in class LinkedBlockingQueue<Runnable>InterruptedExceptionpublic int remainingCapacity()
remainingCapacity in interface BlockingQueue<Runnable>remainingCapacity in class LinkedBlockingQueue<Runnable>public void setForcedRemainingCapacity(Integer forcedRemainingCapacity)
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.