final class RingBufferArb[A] extends RingBuffer[A]
- Alphabetic
- By Inheritance
- RingBufferArb
- RingBuffer
- Serializable
- MutableQueueFieldsPadding
- TailPadding
- PreTailPadding
- HeadPadding
- ClassFieldsPadding
- Serializable
- MutableConcurrentQueue
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        !=(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ##(): Int
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ==(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        asInstanceOf[T0]: T0
      
      
      - Definition Classes
- Any
 
- 
      
      
      
        
      
    
      
        final 
        val
      
      
        capacity: Int
      
      
      The maximum number of elements that a queue can hold. The maximum number of elements that a queue can hold. - Definition Classes
- RingBuffer → MutableConcurrentQueue
- Note
- that unbounded queues can still implement this interface with - capacity = MAX_INT.
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        clone(): AnyRef
      
      
      - Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        dequeuedCount(): Long
      
      
      - returns
- the number of elements that have ever been taken from the queue. 
 - Definition Classes
- RingBuffer → MutableConcurrentQueue
- Note
- if you know how much time the queue is alive, you can calculate the rate at which elements are being dequeued. 
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        enqueuedCount(): Long
      
      
      - returns
- the number of elements that have ever been added to the queue. 
 - Definition Classes
- RingBuffer → MutableConcurrentQueue
- Note
- that scala.Long is used here, since scala.Int will be overflowed really quickly for busy queues. ,- if you know how much time the queue is alive, you can calculate the rate at which elements are being enqueued. 
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        eq(arg0: AnyRef): Boolean
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        equals(arg0: Any): Boolean
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        finalize(): Unit
      
      
      - Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        getClass(): Class[_]
      
      
      - Definition Classes
- AnyRef → Any
- Annotations
- @native()
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        hashCode(): Int
      
      
      - Definition Classes
- AnyRef → Any
- Annotations
- @native()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        isEmpty(): Boolean
      
      
      - Definition Classes
- RingBuffer → MutableConcurrentQueue
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        isFull(): Boolean
      
      
      - Definition Classes
- RingBuffer → MutableConcurrentQueue
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        isInstanceOf[T0]: Boolean
      
      
      - Definition Classes
- Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        ne(arg0: AnyRef): Boolean
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        notify(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @native()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        notifyAll(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @native()
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        offer(a: A): Boolean
      
      
      A non-blocking enqueue. A non-blocking enqueue. - returns
- whether the enqueue was successful or not. 
 - Definition Classes
- RingBuffer → MutableConcurrentQueue
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        poll(default: A): A
      
      
      A non-blocking dequeue. A non-blocking dequeue. - returns
- either an element from the queue, or the - defaultparam.
 - Definition Classes
- RingBuffer → MutableConcurrentQueue
- Note
- that if there's no meaningful default for your type, you can always use - poll(null). Not the best, but reasonable price to pay for lower heap churn from not using scala.Option here.
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        posToIdx(pos: Long, capacity: Int): Int
      
      
      - Attributes
- protected
- Definition Classes
- RingBufferArb → RingBuffer
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        size(): Int
      
      
      - returns
- the current number of elements inside the queue. 
 - Definition Classes
- RingBuffer → MutableConcurrentQueue
- Note
- that this method can be non-atomic and return the approximate number in a concurrent setting. 
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        synchronized[T0](arg0: ⇒ T0): T0
      
      
      - Definition Classes
- AnyRef
 
- 
      
      
      
        
      
    
      
        
        def
      
      
        toString(): String
      
      
      - Definition Classes
- AnyRef → Any
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @throws( ... )
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long, arg1: Int): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @throws( ... )
 
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long): Unit
      
      
      - Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()