java.io.Serializable
, java.lang.Iterable<java.lang.Runnable>
, java.util.Collection<java.lang.Runnable>
, java.util.concurrent.BlockingQueue<java.lang.Runnable>
, java.util.Queue<java.lang.Runnable>
public class TaskQueue
extends java.util.concurrent.LinkedBlockingQueue<java.lang.Runnable>
Modifier and Type | Field | Description |
---|---|---|
protected static StringManager |
sm |
Constructor | Description |
---|---|
TaskQueue() |
|
TaskQueue(int capacity) |
|
TaskQueue(java.util.Collection<? extends java.lang.Runnable> c) |
Modifier and Type | Method | Description |
---|---|---|
boolean |
force(java.lang.Runnable o) |
|
boolean |
force(java.lang.Runnable o,
long timeout,
java.util.concurrent.TimeUnit unit) |
|
boolean |
offer(java.lang.Runnable o) |
|
java.lang.Runnable |
poll(long timeout,
java.util.concurrent.TimeUnit unit) |
|
int |
remainingCapacity() |
|
void |
setForcedRemainingCapacity(java.lang.Integer forcedRemainingCapacity) |
|
void |
setParent(ThreadPoolExecutor tp) |
|
java.lang.Runnable |
take() |
addAll, containsAll, equals, hashCode, isEmpty, parallelStream, stream
clear, contains, drainTo, drainTo, forEach, iterator, offer, peek, poll, put, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString
protected static final StringManager sm
public TaskQueue()
public TaskQueue(int capacity)
public TaskQueue(java.util.Collection<? extends java.lang.Runnable> c)
public void setParent(ThreadPoolExecutor tp)
public boolean force(java.lang.Runnable o)
public boolean force(java.lang.Runnable o, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
public boolean offer(java.lang.Runnable o)
offer
in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
offer
in interface java.util.Queue<java.lang.Runnable>
offer
in class java.util.concurrent.LinkedBlockingQueue<java.lang.Runnable>
public java.lang.Runnable poll(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
poll
in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
poll
in class java.util.concurrent.LinkedBlockingQueue<java.lang.Runnable>
java.lang.InterruptedException
public java.lang.Runnable take() throws java.lang.InterruptedException
take
in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
take
in class java.util.concurrent.LinkedBlockingQueue<java.lang.Runnable>
java.lang.InterruptedException
public int remainingCapacity()
remainingCapacity
in interface java.util.concurrent.BlockingQueue<java.lang.Runnable>
remainingCapacity
in class java.util.concurrent.LinkedBlockingQueue<java.lang.Runnable>
public void setForcedRemainingCapacity(java.lang.Integer forcedRemainingCapacity)
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.