Package akka.dispatch
Class SingleConsumerOnlyUnboundedMailbox
- java.lang.Object
-
- akka.dispatch.SingleConsumerOnlyUnboundedMailbox
-
- All Implemented Interfaces:
MailboxType
,ProducesMessageQueue<NodeMessageQueue>
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
public final class SingleConsumerOnlyUnboundedMailbox extends java.lang.Object implements MailboxType, ProducesMessageQueue<NodeMessageQueue>, scala.Product, scala.Serializable
SingleConsumerOnlyUnboundedMailbox is a high-performance, multiple producer—single consumer, unbounded MailboxType, with the drawback that you can't have multiple consumers, which rules out using it with BalancingPool (BalancingDispatcher) for instance.Currently this queue is slower for some benchmarks than the ConcurrentLinkedQueue from JDK 8 that is used by default, so be sure to measure the performance in your particular setting in order to determine which one to use.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SingleConsumerOnlyUnboundedMailbox()
SingleConsumerOnlyUnboundedMailbox(ActorSystem.Settings settings, com.typesafe.config.Config config)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static SingleConsumerOnlyUnboundedMailbox
apply()
static byte
apply$mcB$sp()
static char
apply$mcC$sp()
static double
apply$mcD$sp()
static float
apply$mcF$sp()
static int
apply$mcI$sp()
static long
apply$mcJ$sp()
static short
apply$mcS$sp()
static void
apply$mcV$sp()
static boolean
apply$mcZ$sp()
boolean
canEqual(java.lang.Object x$1)
SingleConsumerOnlyUnboundedMailbox
copy()
MessageQueue
create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
java.lang.String
toString()
static boolean
unapply(SingleConsumerOnlyUnboundedMailbox x$0)
-
-
-
Constructor Detail
-
SingleConsumerOnlyUnboundedMailbox
public SingleConsumerOnlyUnboundedMailbox()
-
SingleConsumerOnlyUnboundedMailbox
public SingleConsumerOnlyUnboundedMailbox(ActorSystem.Settings settings, com.typesafe.config.Config config)
-
-
Method Detail
-
apply
public static SingleConsumerOnlyUnboundedMailbox apply()
-
unapply
public static boolean unapply(SingleConsumerOnlyUnboundedMailbox x$0)
-
apply$mcZ$sp
public static boolean apply$mcZ$sp()
-
apply$mcB$sp
public static byte apply$mcB$sp()
-
apply$mcC$sp
public static char apply$mcC$sp()
-
apply$mcD$sp
public static double apply$mcD$sp()
-
apply$mcF$sp
public static float apply$mcF$sp()
-
apply$mcI$sp
public static int apply$mcI$sp()
-
apply$mcJ$sp
public static long apply$mcJ$sp()
-
apply$mcS$sp
public static short apply$mcS$sp()
-
apply$mcV$sp
public static void apply$mcV$sp()
-
create
public final MessageQueue create(scala.Option<ActorRef> owner, scala.Option<ActorSystem> system)
- Specified by:
create
in interfaceMailboxType
-
copy
public SingleConsumerOnlyUnboundedMailbox copy()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-