co.paralleluniverse.concurrent.util

Class SingleConsumerNonblockingProducerDelayQueue<E extends java.util.concurrent.Delayed>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue<E>

co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerDelayQueue<E>

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>

public class SingleConsumerNonblockingProducerDelayQueue<E extends java.util.concurrent.Delayed>
extends SingleConsumerNonblockingProducerQueue<E>

Constructor Summary

Constructors

Constructor and Description
SingleConsumerNonblockingProducerDelayQueue()

Method Summary

Modifier and Type	Method and Description
protected boolean	isExpired(E e)
E	poll()
E	poll(long timeout, java.util.concurrent.TimeUnit unit)
E	take()

Methods inherited from class co.paralleluniverse.concurrent.util.SingleConsumerNonblockingProducerQueue

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

Methods inherited from class java.util.AbstractQueue

add, 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.Queue

element, remove

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

SingleConsumerNonblockingProducerDelayQueue

public SingleConsumerNonblockingProducerDelayQueue()

Method Detail

poll

public E poll()

Specified by:

poll in interface java.util.Queue<E extends java.util.concurrent.Delayed>

Overrides:

poll in class SingleConsumerNonblockingProducerQueue<E extends java.util.concurrent.Delayed>

take

public E take()
       throws java.lang.InterruptedException

Specified by:

take in interface java.util.concurrent.BlockingQueue<E extends java.util.concurrent.Delayed>

Overrides:

take in class SingleConsumerNonblockingProducerQueue<E extends java.util.concurrent.Delayed>

Throws:

java.lang.InterruptedException

poll

public E poll(long timeout,
              java.util.concurrent.TimeUnit unit)
       throws java.lang.InterruptedException

Specified by:

poll in interface java.util.concurrent.BlockingQueue<E extends java.util.concurrent.Delayed>

Overrides:

poll in class SingleConsumerNonblockingProducerQueue<E extends java.util.concurrent.Delayed>

Throws:

java.lang.InterruptedException

isExpired

protected boolean isExpired(E e)