C# ConcurrentQueue - 当 Enqueue 发生时引发事件?

Joh*_*ner 4 wcf triggers concurrent-collections

我有一个托管在 Windows 服务中的 WCF 服务。

WCF 服务注入了一个ConcurrentQueue<SomeClass>.

Windows 服务(承载 WCF 服务)也注入了ConcurrentQueue<SomeClass>.

Windows 服务启动 WCF 服务,并生成一个工作线程。

工作线程将 ( Enqueue) 对象推SomeClass送到ConccurrentQueue

我希望以某种方式在对象入ConcurrentQueue队时触发 WCF 服务,以便它可以出队(以及可能在队列中的任何其他对象),并向所有连接的客户端发送消息。

.

两个问题:

  1. 如何在注入的 ConccurentQueue 的“入队”方法上使 WCF 服务“挂钩”,以便当对象被推入队列时 - WCF 服务会对此做些什么?

  2. 如果我确实设法以某种方式挂钩了“入队”事件,并且现在 Windows 服务中的工作线程已将两个对象排入队列 - 这意味着它还会两次“触发”WCF 服务的“入队挂钩” - 那些两个触发事件发生在不同的线程中?我需要以某种方式确保 WCF 服务按顺序从队列中提取对象。我不想突然看到每个 Enqueue 操作 - WCF 服务在单独的线程中触发并将对象拉出......

我希望我的问题足够清楚......

.

[更新]

在与 Chris 交谈后,我得出的结论是,最好的方法是将工作线程与 WCF 服务分开,并使工作线程作为客户端调用 WCF 服务。这意味着我不必摆弄队列。

Chr*_*ris 5

将 ConcurrentQueue 包装在一个公开入队和出队调用的简单类中,然后将您的钩子放在这个类中。每当调用 YourClass.Enqueue 时,触发 WCF 活动,该活动可以调用 YourClass.Dequeue。YourClass.Dequeue 将排空队列并将其放入一个有序的枚举中,然后 WCF 服务可以按顺序处理。