Class UnboundedPriorityMessageQueue

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

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

Constructors

| Improve this Doc View Source

UnboundedPriorityMessageQueue(Func<Object, Int32>, Int32)

Creates a new unbounded priority message queue.

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

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

The initial capacity of the queue.

Properties

| Improve this Doc View Source

LockedCount

Unsafe method for computing the underlying message count.

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

Called from within a synchronization mechanism.

Methods

| Improve this Doc View Source

EnqueueFirst(Envelope)

Declaration
public void EnqueueFirst(Envelope envelope)
Parameters
Type Name Description
Envelope envelope
| Improve this Doc 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.

| Improve this Doc 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
Boolean

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

Called from within a synchronization mechanism.

Implements

Extension Methods