Class WorkerPool.WaitingSynchronousQueue

java.lang.Object

java.util.AbstractCollection<Runnable>

java.util.AbstractQueue<Runnable>

java.util.concurrent.SynchronousQueue<Runnable>

one.nio.server.WorkerPool.WaitingSynchronousQueue

All Implemented Interfaces:

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

Enclosing class:

WorkerPool

private static final class WorkerPool.WaitingSynchronousQueue
extends SynchronousQueue<Runnable>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	queueTime

Constructor Summary

Constructors

Constructor	Description
WaitingSynchronousQueue(long queueTime)

Method Summary

Modifier and Type	Method	Description
boolean	offer(Runnable r)
(package private) void	setQueueTime(long queueTime)

Methods inherited from class SynchronousQueue

clear, contains, containsAll, drainTo, drainTo, isEmpty, iterator, offer, peek, poll, poll, put, remainingCapacity, remove, removeAll, retainAll, size, spliterator, take, 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

queueTime

volatile long queueTime

Constructor Details

WaitingSynchronousQueue

WaitingSynchronousQueue(long queueTime)

Method Details

setQueueTime

void setQueueTime(long queueTime)

offer

public boolean offer(Runnable r)

Specified by:

offer in interface BlockingQueue<Runnable>

Specified by:

offer in interface Queue<Runnable>

Overrides:

offer in class SynchronousQueue<Runnable>