如何强制 GetQueuedCompletionStatus() 立即 return?
How to force GetQueuedCompletionStatus() to return immediately?
我有手工制作的线程池。线程从完成端口读取并做一些其他事情。必须结束一个特定的线程。如果它挂在 GetQueuedCompletionStatus() 或 GetQueuedCompletionStatusEx() 上,如何中断它的等待?
- 有限超时(100-1000 毫秒)和退出变量远非优雅,会导致延迟并留作最后的手段。
- 目标线程中 APC 内的 CancelIo(completionPortHandle) 导致
ERROR_INVALID_HANDLE
。
- CancelSynchronousIo(completionPortHandle) 导致
ERROR_NOT_FOUND
。
- 带有终止数据包的 PostQueuedCompletionStatus() 不允许选择线程。
- 带有互斥量的粗略 TerminateThread() 应该可以工作。 (我没有测试过。)但是它在意识形态上是好的吗?
- 我试图等待特殊事件和完成端口。
WaitForMultipleObjects()
return 立即编辑,就好像完成端口已发出信号一样。 GetQueuedCompletionStatus()
显示没有 return 任何东西。
我阅读了 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
。此函数将使目标线程进入警报状态而无需排队。
我有手工制作的线程池。线程从完成端口读取并做一些其他事情。必须结束一个特定的线程。如果它挂在 GetQueuedCompletionStatus() 或 GetQueuedCompletionStatusEx() 上,如何中断它的等待?
- 有限超时(100-1000 毫秒)和退出变量远非优雅,会导致延迟并留作最后的手段。
- 目标线程中 APC 内的 CancelIo(completionPortHandle) 导致
ERROR_INVALID_HANDLE
。 - CancelSynchronousIo(completionPortHandle) 导致
ERROR_NOT_FOUND
。 - 带有终止数据包的 PostQueuedCompletionStatus() 不允许选择线程。
- 带有互斥量的粗略 TerminateThread() 应该可以工作。 (我没有测试过。)但是它在意识形态上是好的吗?
- 我试图等待特殊事件和完成端口。
WaitForMultipleObjects()
return 立即编辑,就好像完成端口已发出信号一样。GetQueuedCompletionStatus()
显示没有 return 任何东西。
我阅读了 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
。此函数将使目标线程进入警报状态而无需排队。