我已经通过 ManualResetEvent 创建了一个跨进程事件。当此事件确实发生时，n 个不同进程中的 n 个线程可能会被解除阻塞并开始运行以获取新数据。问题是，似乎 ManualResetEvent.Set 后跟立即重置不会导致所有等待线程唤醒。那里的文档很模糊

http://msdn.microsoft.com/en-us/library/windows/desktop/ms682396(v=vs.85).aspx

When the state of a manual-reset event object is signaled, it remains signaled until it is explicitly reset to nonsignaled by the ResetEvent function. Any number of waiting threads, or threads that subsequently begin wait operations for the specified event object, can be released while the object's state is signaled.

有一个方法叫PulseEvent这似乎完全符合我的需要，但不幸的是它也有缺陷。

A thread waiting on a synchronization object can be momentarily removed from the wait state by a kernel-mode APC, and then returned to the wait state after the APC is complete. If the call to PulseEvent occurs during the time when the thread has been removed from the wait state, the thread will not be released because PulseEvent releases only those threads that are waiting at the moment it is called. Therefore, PulseEvent is unreliable and should not be used by new applications. Instead, use condition variables.

现在 MS 确实推荐使用条件变量。

Condition variables are synchronization primitives that enable threads to wait until a particular condition occurs. Condition variables are user-mode objects that cannot be shared across processes.

按照文档，我似乎运气不好，无法可靠地做到这一点。有没有一种简单的方法可以通过一个 ManualResetEvent 来完成同样的事情而没有规定的限制，或者我是否需要为每个监听器进程创建一个响应事件以获得每个订阅的调用者的 ACK？在那种情况下，我需要一个小的共享内存来注册订阅进程的 pid，但这似乎会带来一系列问题。当一个进程崩溃或不响应时会发生什么？ ....

给出一些上下文。我有新的状态要发布，所有其他进程都应该从共享内存位置读取。当多个更新同时发生时错过一个更新是可以的，但该过程必须至少读取最后一个最新值。我可以使用超时进行轮询，但这似乎不是正确的解决方案。

目前我在忙

ChangeEvent = new EventWaitHandle(false, EventResetMode.ManualReset, counterName + "_Event");

ChangeEvent.Set();
Thread.Sleep(1); // increase odds to release all waiters
ChangeEvent.Reset();

最佳答案

处理生产者必须唤醒所有消费者并且消费者数量不断变化的情况的一个通用选项是使用移动栅栏方法。此选项也需要共享内存 IPC 区域。该方法有时确实会导致消费者在没有工作时被唤醒，尤其是当许多进程需要调度并且负载很高时，但它们总是会被唤醒，除非是在无可救药的重载机器上。

创建几个手动重置事件，并让生产者维护一个计数器，以记录下一个将要设置的事件。除 NextToFire 事件外，所有事件均保持设置状态。消费者进程等待 NextToFire 事件。当生产者希望唤醒所有消费者时，它会重置 Next+1 事件并设置当前事件。最终将安排所有消费者，然后等待新的 NextToFire 事件。其效果是只有生产者使用 ResetEvent，但消费者始终知道下一个唤醒他们的事件。

All Users Init:(伪代码是C/C++，不是C#)

// Create Shared Memory and initialise NextToFire;
pSharedMemory = MapMySharedMemory();
if (First to create memory) pSharedMemory->NextToFire = 0;

HANDLE Array[4];
Array[0] = CreateEvent(NULL, 1, 0, "Event1");
Array[1] = CreateEvent(NULL, 1, 0, "Event2");
Array[2] = CreateEvent(NULL, 1, 0, "Event3");
Array[3] = CreateEvent(NULL, 1, 0, "Event4");

生产者唤醒所有

long CurrentNdx = pSharedMemory->NextToFire;
long NextNdx = (CurrentNdx+1) & 3;

// Reset next event so consumers block
ResetEvent(Array[NextNdx]);

// Flag to consumers new value
long Actual = InterlockedIncrement(&pSharedMemory->NextToFire) & 3;

// Next line needed if multiple producers active.
// Not a perfect solution
if (Actual != NextNdx) ResetEvent(Actual);

// Now wake them all up
SetEvent(CurrentNdx);

消费者等待逻辑

long CurrentNdx = (pSharedMemory->NextToFire) & 3;
WaitForSingleObject(Array[CurrentNdx],  Timeout);

关于c# - 跨进程事件 - 可靠地释放所有服务员，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/16393238/