Package one.nio.server
Class WorkerPool.WaitingSynchronousQueue
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- java.util.concurrent.SynchronousQueue<java.lang.Runnable>
-
- one.nio.server.WorkerPool.WaitingSynchronousQueue
-
- All Implemented Interfaces:
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>
- Enclosing class:
- WorkerPool
private static final class WorkerPool.WaitingSynchronousQueue extends java.util.concurrent.SynchronousQueue<java.lang.Runnable>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) longqueueTime
-
Constructor Summary
Constructors Constructor Description WaitingSynchronousQueue(long queueTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanoffer(java.lang.Runnable r)(package private) voidsetQueueTime(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.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
setQueueTime
void setQueueTime(long queueTime)
-
offer
public boolean offer(java.lang.Runnable r)
- Specified by:
offerin interfacejava.util.concurrent.BlockingQueue<java.lang.Runnable>- Specified by:
offerin interfacejava.util.Queue<java.lang.Runnable>- Overrides:
offerin classjava.util.concurrent.SynchronousQueue<java.lang.Runnable>
-
-