Slick
3.6.1
API
Generated with
Slick is developed by Typesafe and EPFL Lausanne.
Slick is developed by Typesafe and EPFL Lausanne.
Slick/slick/slick.util/ManagedArrayBlockingQueue

ManagedArrayBlockingQueue

slick.util.ManagedArrayBlockingQueue
class ManagedArrayBlockingQueue(maximumInUse: Int, capacity: Int, fair: Boolean) extends AbstractQueue[PrioritizedRunnable], BlockingQueue[PrioritizedRunnable], Logging

A simplified copy of java.util.concurrent.ArrayBlockingQueue with additional logic for temporarily rejecting elements based on the current size. All features of the original ArrayBlockingQueue have been ported, except the mutation methods of the iterator. See java.util.concurrent.ArrayBlockingQueue for documentation.

Furthermore this implementation has a pause feature where it does not pass through low- or mid-priority tasks when paused.

Attributes

Source
ManagedArrayBlockingQueue.scala
Graph
Supertypes
trait Logging
trait BlockingQueue[PrioritizedRunnable]
class AbstractQueue[PrioritizedRunnable]
trait Queue[PrioritizedRunnable]
class AbstractCollection[PrioritizedRunnable]
trait Collection[PrioritizedRunnable]
trait Iterable[PrioritizedRunnable]
class Object
trait Matchable
class Any
Show all
Self type

Members list

Value members

Concrete methods

override def clear(): Unit

Attributes

Definition Classes
AbstractQueue -> AbstractCollection -> Collection
Source
ManagedArrayBlockingQueue.scala
override def contains(o: AnyRef): Boolean

Attributes

Definition Classes
BlockingQueue -> AbstractCollection -> Collection
Source
ManagedArrayBlockingQueue.scala
def drainTo(c: Collection[_ >: PrioritizedRunnable]): Int
def drainTo(c: Collection[_ >: PrioritizedRunnable], maxElements: Int): Int
def offer(e: PrioritizedRunnable): Boolean
def offer(e: PrioritizedRunnable, timeout: Long, unit: TimeUnit): Boolean
def poll(timeout: Long, unit: TimeUnit): PrioritizedRunnable
def put(e: PrioritizedRunnable): Unit
override def remove(o: AnyRef): Boolean

Attributes

Definition Classes
BlockingQueue -> AbstractCollection -> Collection
Source
ManagedArrayBlockingQueue.scala
def size: Int

Inherited methods

def add(x$0: PrioritizedRunnable): Boolean

Attributes

Inherited from:
AbstractQueue
def addAll(x$0: Collection[_ <: PrioritizedRunnable]): Boolean

Attributes

Inherited from:
AbstractQueue
def containsAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
AbstractCollection
def element(): E

Attributes

Inherited from:
AbstractQueue
def forEach(x$0: Consumer[_ >: PrioritizedRunnable <: <FromJavaObject>]): Unit

Attributes

Inherited from:
Iterable
def isEmpty(): Boolean

Attributes

Inherited from:
AbstractCollection
def parallelStream(): Stream[E]

Attributes

Inherited from:
Collection
def remove(): E

Attributes

Inherited from:
AbstractQueue
def removeAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
AbstractCollection
def removeIf(x$0: Predicate[_ >: PrioritizedRunnable <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
Collection
def retainAll(x$0: Collection[_ <: <FromJavaObject>]): Boolean

Attributes

Inherited from:
AbstractCollection
def spliterator(): Spliterator[E]

Attributes

Inherited from:
Collection
def stream(): Stream[E]

Attributes

Inherited from:
Collection
def toArray[T <: <FromJavaObject>](x$0: IntFunction[Array[Object & T]]): Array[Object & T]

Attributes

Inherited from:
Collection
def toArray[T <: <FromJavaObject>](x$0: Array[Object & T]): Array[Object & T]

Attributes

Inherited from:
AbstractCollection
def toArray(): Array[<FromJavaObject>]

Attributes

Inherited from:
AbstractCollection
def toString(): String

Returns a string representation of the object.

Returns a string representation of the object.

The default representation is platform dependent.

Attributes

Returns

a string representation of the object.

Inherited from:
AbstractCollection
Generated with
Slick is developed by Typesafe and EPFL Lausanne.
Slick is developed by Typesafe and EPFL Lausanne.