akka.dispatch.sysmsg
Interface SystemMessage

All Superinterfaces:

PossiblyHarmful, java.io.Serializable

All Known Implementing Classes:

Create, DeathWatchNotification, Failed, NoMessage, NoMessage$, Recreate, RemoteWatcher.Rewatch, Resume, Supervise, Suspend, Terminate, Unwatch, Watch

public interface SystemMessage
extends PossiblyHarmful, scala.Serializable

System messages are handled specially: they form their own queue within each actor’s mailbox. This queue is encoded in the messages themselves to avoid extra allocations and overhead. The next pointer is a normal var, and it does not need to be volatile because in the enqueuing method its update is immediately succeeded by a volatile write and all reads happen after the volatile read in the dequeuing thread. Afterwards, the obtained list of system messages is handled in a single thread only and not ever passed around, hence no further synchronization is needed.

INTERNAL API

➡➡➡ NEVER SEND THE SAME SYSTEM MESSAGE OBJECT TO TWO ACTORS ⬅⬅⬅

Method Summary

SystemMessage	next()
void	unlink()
boolean	unlinked()

Method Detail

next

SystemMessage next()

unlink

void unlink()

unlinked

boolean unlinked()