class CallingThreadMailbox extends Mailbox with DefaultSystemMessageQueue
- Alphabetic
- By Inheritance
- CallingThreadMailbox
- DefaultSystemMessageQueue
- Mailbox
- Runnable
- SystemMessageQueue
- ForkJoinTask
- Serializable
- Future
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new CallingThreadMailbox(_receiver: Cell, mailboxType: MailboxType)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to any2stringadd[CallingThreadMailbox] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (CallingThreadMailbox, B)
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to ArrowAssoc[CallingThreadMailbox] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
var
_statusDoNotCallMeDirectly: Status
- Attributes
- protected
- Definition Classes
- Mailbox
-
var
_systemQueueDoNotCallMeDirectly: SystemMessage
- Attributes
- protected
- Definition Classes
- Mailbox
-
var
actor: ActorCell
- Definition Classes
- Mailbox
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
final
def
becomeClosed(): Boolean
set new primary status Closed.
set new primary status Closed. Caller does not need to worry about whether status was Scheduled or not.
- Definition Classes
- Mailbox
- Annotations
- @tailrec()
-
final
def
canBeScheduledForExecution(hasMessageHint: Boolean, hasSystemMessageHint: Boolean): Boolean
- Definition Classes
- Mailbox
-
def
cancel(arg0: Boolean): Boolean
- Definition Classes
- ForkJoinTask → Future
-
def
cleanUp(): Unit
Overridable callback to clean up the mailbox, called when an actor is unregistered.
Overridable callback to clean up the mailbox, called when an actor is unregistered. By default it dequeues all system messages + messages and ships them to the owning actors' systems' DeadLetterMailbox
- Definition Classes
- CallingThreadMailbox → Mailbox
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
compareAndSetForkJoinTaskTag(arg0: Short, arg1: Short): Boolean
- Definition Classes
- ForkJoinTask
-
def
complete(arg0: Unit): Unit
- Definition Classes
- ForkJoinTask
-
def
completeExceptionally(arg0: Throwable): Unit
- Definition Classes
- ForkJoinTask
- val ctdLock: ReentrantLock
-
final
def
currentStatus: Status
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
def
dequeue(): Envelope
Try to dequeue the next message from this queue, return null failing that.
Try to dequeue the next message from this queue, return null failing that.
- Definition Classes
- CallingThreadMailbox → Mailbox
-
def
dispatcher: MessageDispatcher
- Definition Classes
- Mailbox
-
def
enqueue(receiver: ActorRef, msg: Envelope): Unit
Try to enqueue the message to this queue, or throw an exception.
Try to enqueue the message to this queue, or throw an exception.
- Definition Classes
- CallingThreadMailbox → Mailbox
-
def
ensuring(cond: (CallingThreadMailbox) ⇒ Boolean, msg: ⇒ Any): CallingThreadMailbox
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to Ensuring[CallingThreadMailbox] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (CallingThreadMailbox) ⇒ Boolean): CallingThreadMailbox
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to Ensuring[CallingThreadMailbox] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): CallingThreadMailbox
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to Ensuring[CallingThreadMailbox] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): CallingThreadMailbox
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to Ensuring[CallingThreadMailbox] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
exec(): Boolean
- Definition Classes
- Mailbox → ForkJoinTask
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
fork(): ForkJoinTask[Unit]
- Definition Classes
- ForkJoinTask
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to StringFormat[CallingThreadMailbox] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
get(arg0: Long, arg1: TimeUnit): Unit
- Definition Classes
- ForkJoinTask → Future
- Annotations
- @throws( ... ) @throws( ... ) @throws( ... )
-
final
def
get(): Unit
- Definition Classes
- ForkJoinTask → Future
- Annotations
- @throws( ... ) @throws( ... )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
final
def
getException(): Throwable
- Definition Classes
- ForkJoinTask
-
final
def
getForkJoinTaskTag(): Short
- Definition Classes
- ForkJoinTask
-
final
def
getRawResult(): Unit
- Definition Classes
- Mailbox → ForkJoinTask
-
def
hasMessages: Boolean
Indicates whether this queue is non-empty.
Indicates whether this queue is non-empty.
- Definition Classes
- CallingThreadMailbox → Mailbox
-
def
hasSystemMessages: Boolean
- Definition Classes
- DefaultSystemMessageQueue
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
invoke(): Unit
- Definition Classes
- ForkJoinTask
-
final
def
isCancelled(): Boolean
- Definition Classes
- ForkJoinTask → Future
-
final
def
isClosed: Boolean
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
final
def
isCompletedAbnormally(): Boolean
- Definition Classes
- ForkJoinTask
-
final
def
isCompletedNormally(): Boolean
- Definition Classes
- ForkJoinTask
-
final
def
isDone(): Boolean
- Definition Classes
- ForkJoinTask → Future
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
isScheduled: Boolean
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
final
def
isSuspended: Boolean
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
final
def
join(): Unit
- Definition Classes
- ForkJoinTask
- val mailboxType: MailboxType
-
val
messageQueue: MessageQueue
This is only a marker to be put in the messageQueue’s stead to make error messages pertaining to violated mailbox type requirements less cryptic.
This is only a marker to be put in the messageQueue’s stead to make error messages pertaining to violated mailbox type requirements less cryptic.
- Definition Classes
- CallingThreadMailbox → Mailbox
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
numberOfMessages: Int
Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently.
Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently. Do not use this for testing for presence of messages, use
hasMessages
instead.- Definition Classes
- CallingThreadMailbox → Mailbox
-
final
def
processAllSystemMessages(): Unit
Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …).
Will at least try to process all queued system messages: in case of failure simply drop and go on to the next, because there is nothing to restart here (failure is in ActorCell somewhere …). In case the mailbox becomes closed (because of processing a Terminate message), dump all already dequeued message to deadLetters.
- Definition Classes
- Mailbox
- def queue: MessageQueue
-
final
def
quietlyComplete(): Unit
- Definition Classes
- ForkJoinTask
-
final
def
quietlyInvoke(): Unit
- Definition Classes
- ForkJoinTask
-
final
def
quietlyJoin(): Unit
- Definition Classes
- ForkJoinTask
-
def
reinitialize(): Unit
- Definition Classes
- ForkJoinTask
-
final
def
resume(): Boolean
Reduce the suspend count by one.
Reduce the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.
- returns
true if the suspend count reached zero
- Definition Classes
- Mailbox
- Annotations
- @tailrec()
-
final
def
run(): Unit
- Definition Classes
- Mailbox → Runnable
- val self: ActorRef
-
def
setActor(cell: ActorCell): Unit
- Definition Classes
- Mailbox
-
final
def
setAsIdle(): Boolean
Reset Scheduled status, keeping primary status as is.
Reset Scheduled status, keeping primary status as is.
- Definition Classes
- Mailbox
- Annotations
- @tailrec()
-
final
def
setAsScheduled(): Boolean
Set Scheduled status, keeping primary status as is.
Set Scheduled status, keeping primary status as is.
- Definition Classes
- Mailbox
- Annotations
- @tailrec()
-
final
def
setForkJoinTaskTag(arg0: Short): Short
- Definition Classes
- ForkJoinTask
-
final
def
setRawResult(unit: Unit): Unit
- Definition Classes
- Mailbox → ForkJoinTask
-
final
def
setStatus(newStatus: Status): Unit
- Attributes
- protected
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
final
def
shouldProcessMessage: Boolean
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
final
def
suspend(): Boolean
Increment the suspend count by one.
Increment the suspend count by one. Caller does not need to worry about whether status was Scheduled or not.
- returns
true if the previous suspend count was zero
- Definition Classes
- Mailbox
- Annotations
- @tailrec()
-
final
def
suspendCount: Int
- Definition Classes
- Mailbox
- Annotations
- @inline()
- val suspendSwitch: Switch
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- val system: ActorSystem
-
final
def
systemDrain(newContents: LatestFirstSystemMessageList): EarliestFirstSystemMessageList
- Definition Classes
- DefaultSystemMessageQueue
- Annotations
- @tailrec()
-
final
def
systemEnqueue(receiver: ActorRef, message: SystemMessage): Unit
- Definition Classes
- DefaultSystemMessageQueue
- Annotations
- @tailrec()
-
final
def
systemQueueGet: LatestFirstSystemMessageList
- Attributes
- protected
- Definition Classes
- Mailbox
-
final
def
systemQueuePut(_old: LatestFirstSystemMessageList, _new: LatestFirstSystemMessageList): Boolean
- Attributes
- protected
- Definition Classes
- Mailbox
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
def
tryUnfork(): Boolean
- Definition Classes
- ForkJoinTask
-
final
def
updateStatus(oldStatus: Status, newStatus: Status): Boolean
- Attributes
- protected
- Definition Classes
- Mailbox
- Annotations
- @inline()
-
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( ... )
-
def
→[B](y: B): (CallingThreadMailbox, B)
- Implicit
- This member is added by an implicit conversion from CallingThreadMailbox to ArrowAssoc[CallingThreadMailbox] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc