c

akka.util

BoundedBlockingQueue

class BoundedBlockingQueue[E <: AnyRef] extends AbstractQueue[E] with BlockingQueue[E]

BoundedBlockingQueue wraps any Queue and turns the result into a BlockingQueue with a limited capacity.

Source
BoundedBlockingQueue.scala
Linear Supertypes
BlockingQueue[E], AbstractQueue[E], Queue[E], AbstractCollection[E], Collection[E], Iterable[E], AnyRef, Any
Known Subclasses
MessageQueue, MessageQueue
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BoundedBlockingQueue
  2. BlockingQueue
  3. AbstractQueue
  4. Queue
  5. AbstractCollection
  6. Collection
  7. Iterable
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new BoundedBlockingQueue(maxCapacity: Int, backing: Queue[E])

    maxCapacity

    - the maximum capacity of this Queue, needs to be > 0

    backing

    - the backing Queue

Value Members

  1. def add(arg0: E): Boolean
    Definition Classes
    AbstractQueue → Queue → AbstractCollection → Collection
  2. def addAll(arg0: Collection[_ <: E]): Boolean
    Definition Classes
    AbstractQueue → AbstractCollection → Collection
  3. def clear(): Unit
    Definition Classes
    BoundedBlockingQueue → AbstractQueue → AbstractCollection → Collection
  4. def contains(e: AnyRef): Boolean
    Definition Classes
    BoundedBlockingQueue → BlockingQueue → AbstractCollection → Collection
  5. def containsAll(c: Collection[_]): Boolean
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  6. def drainTo(c: Collection[_ >: E], maxElements: Int): Int
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  7. def drainTo(c: Collection[_ >: E]): Int
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  8. def element(): E
    Definition Classes
    AbstractQueue → Queue
  9. def forEach(arg0: Consumer[_ >: E <: AnyRef]): Unit
    Definition Classes
    Iterable
  10. def isEmpty(): Boolean
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  11. def iterator(): Iterator[E]
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection → Iterable
  12. val maxCapacity: Int
  13. def offer(e: E, timeout: Long, unit: TimeUnit): Boolean
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  14. def offer(e: E): Boolean
    Definition Classes
    BoundedBlockingQueue → BlockingQueue → Queue
  15. def parallelStream(): Stream[E]
    Definition Classes
    Collection
  16. def peek(): E
    Definition Classes
    BoundedBlockingQueue → Queue
  17. def poll(): E
    Definition Classes
    BoundedBlockingQueue → Queue
  18. def poll(timeout: Long, unit: TimeUnit): E
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  19. def put(e: E): Unit
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  20. def remainingCapacity(): Int
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  21. def remove(e: AnyRef): Boolean
    Definition Classes
    BoundedBlockingQueue → BlockingQueue → AbstractCollection → Collection
  22. def remove(): E
    Definition Classes
    AbstractQueue → Queue
  23. def removeAll(c: Collection[_]): Boolean
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  24. def removeIf(arg0: Predicate[_ >: E <: AnyRef]): Boolean
    Definition Classes
    Collection
  25. def retainAll(c: Collection[_]): Boolean
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  26. def size(): Int
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  27. def spliterator(): Spliterator[E]
    Definition Classes
    Collection → Iterable
  28. def stream(): Stream[E]
    Definition Classes
    Collection
  29. def take(): E
    Definition Classes
    BoundedBlockingQueue → BlockingQueue
  30. def toArray[X](a: Array[X]): Array[X]
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  31. def toArray(): Array[AnyRef]
    Definition Classes
    BoundedBlockingQueue → AbstractCollection → Collection
  32. def toArray[T <: AnyRef](arg0: IntFunction[Array[T]]): Array[T]
    Definition Classes
    Collection
  33. def toString(): String
    Definition Classes
    AbstractCollection → AnyRef → Any