从主线程向工作线程发出信号的问题

Question

我必须对输入文件 (1...N) 执行 OperationA，然后我必须对 operationA 完成的文件执行 OperationB。

所以在主线程中我遍历每个文件（1...N）并执行操作A。然后将文件推送到线程安全队列并继续处理下一个文件。工作线程从队列中获取文件并执行操作 B。 为了实现这一点，我使用了如下事件：

HANDLE hEvent =CreateEvent(NULL, FALSE/*autoreset*/, FALSE/*nonsignaled*/, "");
for( files 1... N)
{
   1. Operation A
   2. Push file to the queue
   3. SetEvent( hEvent )
}

WorkerThread()
{
   while(1)
   {
      1. WaitforSingleObject( hEvent , INFINITE )
      2. operation B
   }
}

我期望的是每个 SetEvent() 都会发出 WaitforSingleObject() 信号。 但实际行为并非如此。 即，对于第一个 SetEvent，WaitforSingleObject 发出信号。 当 operationB 正在进行时，许多 SetEvents 正在从主线程触发。因此，下一个 WaitforSingleObject() 应该立即发出信号，因为第二个 SetEvent 已经被触发。但这并没有按预期工作。

• 设置事件
  • WaitforSingleObject
• 设置事件
• 设置事件
• 设置事件
  • WaitforSingleObject
• 设置事件
• 设置事件
  • WaitforSingleObject

我为 6 个文件调用了 6 个 setevent。但是 WaitforSingleObject 只发出 3 个信号。

首先请告诉我我是否使用了正确的上下文同步机制？

Answer 1

这是生产者-消费者问题，你可以用信号量来解决。

查看此链接https://en.wikipedia.org/wiki/Producer%E2%80%93consumer_problem

您的代码在链接中的实现不充分。

使用信号量，代码将按预期运行。