QueueOfIterator

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. def aroundPostRestart(reason: Throwable): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

5. def aroundPostStop(): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

6. def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

7. def aroundPreStart(): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

8. def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

   

   Attributes

   protected[akka]

   Definition Classes

   Actor

9. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

10. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

11. implicit val context: ActorContext

    

    Definition Classes

    Actor

12. def delayedMsg(delay: FiniteDuration, msg: Any, receiver: ActorRef = self): Cancellable

    

    Definition Classes

    MessageScheduler

13. final def dispatchWork(state: InternalState, dispatched: Int = 0, retiring: Boolean = false): InternalState

    

    Dispatch as many as possible work, so by the end either work queue or worker queue should be empty.

    Dispatch as many as possible work, so by the end either work queue or worker queue should be empty. Note that the workers left in the worker queue after dispatch are the only ones that counts as idle workers.

    Attributes

    protected

    Definition Classes

    Queue

    Annotations

    @tailrec()

14. val enqueuer: ActorRef

    

15. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

16. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

17. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

18. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

19. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

20. val initialState: InternalState

    

    Definition Classes

    Queue

21. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

22. def log: LoggingAdapter

    

    Definition Classes

    ActorLogging

23. def maybeDelayedMsg(delayO: Option[FiniteDuration], msg: Any, receiver: ActorRef = self): Option[Cancellable]

    

    Definition Classes

    MessageScheduler

24. val metricsCollector: ActorRef

    

    Definition Classes

    QueueOfIterator → Queue

25. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

26. final def notify(): Unit

    

    Definition Classes

    AnyRef

27. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

28. def onQueuedWorkExhausted(): Unit

    

    Definition Classes

    QueueOfIterator → Queue

29. def postRestart(reason: Throwable): Unit

    

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

30. def postStop(): Unit

    

    Definition Classes

    Queue → Actor

31. def preRestart(reason: Throwable, message: Option[Any]): Unit

    

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

32. def preStart(): Unit

    

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

33. final def processing(state: InternalState): Receive

    

    Definition Classes

    Queue

34. final def receive: Receive

    

    Definition Classes

    Queue → Actor

35. val reportScheduler: Cancellable

    

    Definition Classes

    Queue

36. final def retiring(state: InternalState): Receive

    

    Definition Classes

    Queue

37. implicit final val self: ActorRef

    

    Definition Classes

    Actor

38. final def sender(): ActorRef

    

    Definition Classes

    Actor

39. def supervisorStrategy: SupervisorStrategy

    

    Definition Classes

    Actor

40. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

41. def toString(): String

    

    Definition Classes

    AnyRef → Any

42. def unhandled(message: Any): Unit

    

    Definition Classes

    Actor

43. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

44. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

45. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

46. def workBuffered(state: InternalState): Boolean

    

    Determines if a state indicates the workers pool are all busy.

    Determines if a state indicates the workers pool are all busy. This is different from the default pushing DefaultQueue for a QueueOfIterator, it only gets work when there is at least one queued worker, which means there is a significant chance a second worker comes in before the first worker gets work. This number is still a bit arbitrary though. Obviously we still have to chose an arbitrary number as the threshold of queued workers with which we deem the queue as partially utilized. Todo: Right now we lack the insight of how to set this up correctly so I'd rather have it hard coded for now than allowing our users to tweak it without giving them any guidance

    Definition Classes

    QueueOfIterator → Queue

47. val workSettings: WorkSettings

    

    Definition Classes

    QueueOfIterator → Queue