C＃事件多个发布者到一个订阅者

Question

我有一段代码有两个事件处理程序。我希望这两个事件处理程序通知另一种方法，即有一些工作要做。

我已经实现了这个使用ManualResetEvent，但我不确定这是否是实现我想要的最好方法，或者是否有更好的方法。

static ManualResetEvent autoEvent = new ManualResetEvent(false); 

void begin() { 
    ThreadPool.QueueUserWorkItem(new WaitCallback(genericHandler)); 
} 

void OnEvent1(object sender) { 
    autoEvent.Set(); 
} 

void OnEvent2(object sender) { 
    autoEvent.Set(); 
} 

void genericHandler(object info) { 
    while (true) { 
     autoEvent.WaitOne(); 
     // do some work 
    } 
} 

一个我拥有的最重要的问题是：autoEvent.WaitOne()后，我做了一些工作，这些工作耗费的时间。与此同时，另一个事件被触发，并且在genericHandler再次获得WaitOne()之前调用Set()。当再次到达WaitOne时，它是否会等待另一个Set()，或者在达到WaitOne()之前调用Set()之前继续？

这是在C＃中实现多个发布者和一个订户模式的最佳方式吗？或者我应该使用另一件事物而不是ManualResetEvent？

注意：genericHandler位于不同的线程中，因为Event1和Event2具有不同的优先级，所以在处理程序中，我会在检查Event2之前检查Event1是否有挂起的工作。

Answer 1

你的代码确实做了你认为它所做的事情，你描述的竞争条件根本不是问题。按照MRE的文件，当它被设置时，它将保持在“信号”状态，直到通过呼叫WaitOne重置为止。

Answer 2

问题和代码太模糊地提出，以提供良好的具体建议。这就是说...

不，使用ManualResetEvent在这里不合适。它不仅不必要地使代码复杂化，而且代码依赖于从线程池中取得的长时间运行的线程（只执行短期任务）。

如果您需要触发执行某些异步工作的事件，那么您应该使用async/await模式，其中每个新工作单元都通过Task类调​​用。

例如：

async void OnEvent1(object sender) { 
    var workUnit = ... ; // something here that represents your unit of work 
    await Task.Run(() => genericHandler(workUnit)); 
} 

void OnEvent2(object sender) { 
    var workUnit = ... ; // something here that represents your unit of work 
    await Task.Run(() => genericHandler(workUnit)); 
} 

void genericHandler(object info) { 
    // do some work using info 
} 

注意，事件对象以及begin()方法完全消除。

从你的问题来看，并不清楚每个工作单位是否完全相互独立。如果不是，那么您可能还需要一些同步来保护共享数据。再次，没有一个更具体的问题，不可能说出这将是什么，但最有可能使用lock声明或Concurrent...集合之一。