我是活动和代表的新手。如何为Queue<T>
类型的对象实现入队事件?
我正在使用C#和.Net 4.0
您可以使用自己的类封装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!
没有从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一起使用的方法。