如何强制 GetQueuedCompletionStatus() 立即 return?

How to force GetQueuedCompletionStatus() to return immediately?

我有手工制作的线程池。线程从完成端口读取并做一些其他事情。必须结束一个特定的线程。如果它挂在 GetQueuedCompletionStatus() 或 GetQueuedCompletionStatusEx() 上,如何中断它的等待?

我阅读了 Overlapped I/O: How to wake a thread on a completion port event or a normal event? 并在谷歌上搜索了很多。

问题本身——结束线程的工作——可能是设计不当的标志,我的所有线程应该是平等的,并混合到正常的线程池中。在这种情况下,PostQueuedCompletionStatus() 方法应该起作用。 (尽管我怀疑这种方法是否美观简洁,尤其是当线程使用 GetQueuedCompletionStatusEx() 一次获取多个数据包时。)

如果您只是想减小线程池的大小,那么退出哪个线程并不重要。

但是,如果出于某种原因您需要向特定线程发出它需要退出的信号,而不是允许任何线程退出,您可以使用此方法。

如果您使用 GetQueuedCompletionStatusEx,您可以通过将 TRUE 传递给 fAlertable 来进行提醒等待。然后,您可以使用 QueueUserAPC 将 APC 排队到要退出的线程。

如果线程正忙,那么您仍然需要等待当前工作项完成。

当然不要调用TerminateThread。

不幸的是,I/O 完成端口句柄始终处于信号状态,因此不能真正用于 WaitFor* 函数。

GetQueuedCompletionStatus[Ex] 是阻塞完成端口的唯一方法。对于空队列,只有当线程被提醒时,该函数才会 return 。正如@Ben 所提到的,QueueUserAPC 将使线程被警告并导致 GetQueuedCompletionStatus 到 return。

但是,QueueUserAPC 分配内存,因此在内存不足或内存配额生效时可能会失败。 PostQueuedCompletionStatus也是如此。因此,在退出路径上使用这些函数中的任何一个都不是一个好主意。

不幸的是,唯一可靠的方法似乎是调用 ntdll.dll.

导出的未记录的 NtAlertThread
extern "C" NTSTATUS __stdcall NtAlertThread(HANDLE hThread);

Link 与 ntdll.lib。此函数将使目标线程进入警报状态而无需排队。