Class CoDelBlockingQueue<E extends CDQEntry>

  • All Implemented Interfaces:
    Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

    public class CoDelBlockingQueue<E extends CDQEntry>
    extends LinkedBlockingQueue<E>
    CoDel implementation of Active Queue Management. Ref: http://queue.acm.org/detail.cfm?id=2209336 Ref: http://queue.acm.org/appendices/codel.html Code and comments are directly from appendix above, apparently public domain. Input: add(), offer(), and put() are overridden to add a timestamp. Output : take(), poll(), and drainTo() are overridden to implement AQM and drop entries if necessary. peek(), and remove() are NOT overridden, and do NOT implement AQM or update stats.
    Since:
    0.9.3
    See Also:
    Serialized Form