Class UnboundedStablePriorityMessageQueue

Base class for a message queue that uses a priority generator for messages

Inheritance
object
BlockingMessageQueue
UnboundedStablePriorityMessageQueue
Implements
Inherited Members
Namespace: Akka.Dispatch.MessageQueues
Assembly: Akka.dll
Syntax
public class UnboundedStablePriorityMessageQueue : BlockingMessageQueue, IMessageQueue, IBlockingMessageQueueSemantics, IMultipleConsumerSemantics, IUnboundedDequeBasedMessageQueueSemantics, IDequeBasedMessageQueueSemantics, IUnboundedMessageQueueSemantics, ISemantics

Constructors

| Edit this page View Source

UnboundedStablePriorityMessageQueue(Func<object, int>, int)

Creates a new unbounded priority message queue.

Declaration
public UnboundedStablePriorityMessageQueue(Func<object, int> priorityGenerator, int initialCapacity)
Parameters
Type Name Description
Func<object, int> priorityGenerator

The calculator function for determining the priority of inbound messages.
int initialCapacity

The initial capacity of the queue.

Properties

| Edit this page View Source

LockedCount

Unsafe method for computing the underlying message count.

Declaration
protected override int LockedCount { get; }
Property Value
Type Description
int
Overrides
Remarks

Called from within a synchronization mechanism.

Methods

| Edit this page View Source

EnqueueFirst(Envelope)

TBD

Declaration
public void EnqueueFirst(Envelope envelope)
Parameters
Type Name Description
Envelope envelope

TBD
| Edit this page View Source

LockedEnqueue(Envelope)

Unsafe method for enqueuing a new message to the queue.

Declaration
protected override void LockedEnqueue(Envelope envelope)
Parameters
Type Name Description
Envelope envelope

The message to enqueue.
Overrides
Remarks

Called from within a synchronization mechanism.

| Edit this page View Source

LockedTryDequeue(out Envelope)

Unsafe method for attempting to dequeue a message.

Declaration
protected override bool LockedTryDequeue(out Envelope envelope)
Parameters
Type Name Description
Envelope envelope

The message that might be dequeued.
Returns
Type Description
bool

true if a message was available to be dequeued, false otherwise.
Overrides
Remarks

Called from within a synchronization mechanism.

Implements

Extension Methods