Class TransportFilter.QueuingExecutor.HandOffQueue

java.lang.Object

java.util.AbstractCollection<Runnable>

java.util.AbstractQueue<Runnable>

java.util.concurrent.SynchronousQueue<Runnable>

org.glassfish.jersey.jdk.connector.internal.TransportFilter.QueuingExecutor.HandOffQueue

All Implemented Interfaces:

Serializable, Iterable<Runnable>, Collection<Runnable>, BlockingQueue<Runnable>, Queue<Runnable>

Enclosing class:

TransportFilter.QueuingExecutor

private static class TransportFilter.QueuingExecutor.HandOffQueue
extends SynchronousQueue<Runnable>

Synchronous queue that tries to empty taskQueue before it blocks waiting for new tasks to be submitted. It is passed to ThreadPoolExecutor, where it is used used to hand off tasks from task-submitting thread to worker threads.

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID
private final Queue<Runnable>	taskQueue
private final boolean	threadSafeQueue

Constructor Summary

Constructors

Modifier	Constructor	Description
private	HandOffQueue(Queue<Runnable> taskQueue, boolean threadSafeQueue)

Method Summary

Modifier and Type	Method	Description
Runnable	poll(long timeout, TimeUnit unit)
Runnable	take()

Methods inherited from class SynchronousQueue

clear, contains, containsAll, drainTo, drainTo, isEmpty, iterator, offer, offer, peek, poll, put, remainingCapacity, remove, removeAll, retainAll, size, spliterator, toArray, toArray, toString

Methods inherited from class AbstractQueue

add, addAll, element, remove

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface BlockingQueue

add

Methods inherited from interface Collection

addAll, equals, hashCode, parallelStream, removeIf, stream, toArray

Methods inherited from interface Iterable

forEach

Methods inherited from interface Queue

element, remove

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

taskQueue

private final Queue<Runnable> taskQueue

threadSafeQueue

private final boolean threadSafeQueue

Constructor Details

HandOffQueue

private HandOffQueue(Queue<Runnable> taskQueue,
 boolean threadSafeQueue)

Method Details

take

public Runnable take()
              throws InterruptedException

Specified by:

take in interface BlockingQueue<Runnable>

Overrides:

take in class SynchronousQueue<Runnable>

Throws:

InterruptedException

poll

public Runnable poll(long timeout,
 TimeUnit unit)
              throws InterruptedException

Specified by:

poll in interface BlockingQueue<Runnable>

Overrides:

poll in class SynchronousQueue<Runnable>

Throws:

InterruptedException