ManagedArrayBlockingQueue
slick.util.ManagedArrayBlockingQueue
class ManagedArrayBlockingQueue(maximumInUse: Int, capacity: Int, fair: Boolean) extends AbstractQueue[PrioritizedRunnable] with BlockingQueue[PrioritizedRunnable] with 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 Loggingtrait BlockingQueue[PrioritizedRunnable]class AbstractQueue[PrioritizedRunnable]trait Queue[PrioritizedRunnable]class AbstractCollection[PrioritizedRunnable]trait Collection[PrioritizedRunnable]trait Iterable[PrioritizedRunnable]class Objecttrait Matchableclass Any
- Self type