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 java.util.concurrent.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 java.util.AbstractQueue
add, addAll, element, remove

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue
add

Methods inherited from interface java.util.Collection
addAll, equals, hashCode, parallelStream, removeIf, stream, toArray

Methods inherited from interface java.lang.Iterable
forEach

Methods inherited from interface java.util.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>