BaseMessageQueue
StockSharp.Messages
Base implementation of IMessageQueue.
继承自: BaseOrderedChannel<long, Message, PriorityQueue<long, Message>>
实现: IMessageQueue, ICloneable<IMessageQueue>, ICloneable
构造函数
BaseMessageQueue
protected BaseMessageQueue()baseMessageQueue = BaseMessageQueue()Base implementation of IMessageQueue.
方法
Clone
public abstract IMessageQueue Clone()result = baseMessageQueue.Clone()Creates a deep copy of a DataSeries
Enqueue
public abstract ValueTask Enqueue(Message message, CancellationToken cancellationToken)result = baseMessageQueue.Enqueue(message, cancellationToken)将指定的消息排入正序 。
- message
- 信息要排队。
- cancellationToken
- 取消的代币。