Queue 在C#中排队的事件

问题描述 投票:3回答:2

我是活动和代表的新手。如何为Queue<T>类型的对象实现入队事件?

我正在使用C#和.Net 4.0

c# .net events delegates .net-4.0
2个回答
16
投票

您可以使用自己的类封装Queue类,例如:

class MyQueue<T>
{
    private readonly Queue<T> queue = new Queue<T>();     
    public event EventHandler Enqueued;     
    protected virtual void OnEnqueued()     
    {         
        if (Enqueued != null) 
        Enqueued(this, EventArgs e);     
    }     
    public virtual void Enqueue(T item)     
    {         
        queue.Enqueue(item);         
        OnEnqueued();     
    }     
    public int Count 
     {
             get 
             { 
                     return queue.Count; 
             }
     }
    public virtual T Dequeue()     
    {
            T item = queue.Dequeue();         
            OnEnqueued();
            return item;
        }
} 

HTH!


6
投票

没有从System.Collections。*类套件中激发的事件。由于使用的是.NET 4.0,因此您可能需要研究BlockingCollection<T>,而不是依赖于事件,而是使用BlockingCollection<T>从集合中获取元素,因为它们是从另一个线程到达的。 the Producer-Consumer pattern将为您有效地处理所有线程安全和同步。

BlockingCollection<T>的默认背景类型是BlockingCollection<T>,这听起来像您想要的,但是应注意,如果您想/不要介意,可以将其更改为使用BlockingCollection<T>BlockingCollection<T>订购特征。

ConcurrentQueue<T>的另一个重要功能是ConcurrentQueue<T>的功能,它可以帮助阻止生产者向集合中添加比消费者无法承受的更多项目。

[有关该主题各个方面的精彩文章,我建议您从Alexeandra Rusina查阅ConcurrentStack<T>。该帖子还介绍了使用ConcurrentStack<T>与BlockingCollection一起使用的方法。

© www.soinside.com 2019 - 2024. All rights reserved.