除非收到消息，否则有没有办法睡觉？

Question

我在一个主循环如下所示的服务中工作：

while (fServer.ServerState = ssStarted) and (Self.Terminated = false) do
begin
  Self.ServiceThread.ProcessRequests(false);
  ProcessFiles;
  Sleep(3000);      
end;

ProcessRequests 很像Application.ProcessMessages。我不能将true 传递给它，因为如果我这样做了，它就会阻塞，直到收到来自 Windows 的消息，并且 ProcessFiles 不会运行，它必须不断运行。睡眠可以降低 CPU 使用率。

在我尝试从 Windows 的服务管理列表中关闭该服务之前，这一切正常。当我点击 Stop 时，它会发送一条消息并期望几乎立即得到响应，如果它在 Sleep 命令的中间，Windows 会给我一个错误，表明该服务没有响应 Stop 命令。

所以我需要说“睡眠 3000 或直到您收到消息，以先到者为准。”我确定有一个 API，但我不确定它是什么。有人知道吗？

Answer 1

这类东西很难搞定，所以我通常从 MSDN 的 API 文档开始。

WaitForSingleObject 文档针对这些情况专门针对MsgWaitForMultipleObjects：

调用等待时要小心 直接或 间接创建窗口。如果一个 线程创建任何窗口，它必须 处理消息。消息广播 发送到系统中的所有窗口。 使用等待函数的线程 没有超时间隔可能会导致 系统陷入僵局。二 间接的代码示例 创建窗口是 DDE 和 CoInitialize 函数。因此，如果 你有一个线程创建 窗户，使用MsgWaitForMultipleObjects 或MsgWaitForMultipleObjectsEx，而不是 比WaitForSingleObject.

在MsgWaitForMultipleObjects 中，您有一个dwWakeMask 参数指定要返回的排队消息，以及一个描述您可以使用的掩码的表格。

编辑因为Warren P的评论：

如果由于ReadFileEx、WriteFileEx 或QueueUserAPC 而您的主循环可以继续，那么您可以使用SleepEx。

--杰罗恩

Answer 2

MsgWaitForMultipleObjects() 是要走的路，即：

while (fServer.ServerState = ssStarted) and (not Self.Terminated) do 
begin 
  ProcessFiles; 
  if MsgWaitForMultipleObjects(0, nil, FALSE, 3000, QS_ALLINPUT) = WAIT_OBJECT_0 then
    Self.ServiceThread.ProcessRequests(false); 
end;

如果您想以 3 秒的间隔调用 ProcessFiles() 而不管是否有任何消息到达，那么您可以为此使用等待计时器，即：

var
  iDue: TLargeInteger;
  hTimer: array[0..0] of THandle;
begin
  iDue := -30000000; // 3 second relative interval, specified in nanoseconds
  hTimer[0] := CreateWaitableTimer(nil, False, nil);
  SetWaitableTimer(hTimer[0], iDue, 0, nil, nil, False);
  while (fServer.ServerState = ssStarted) and (not Self.Terminated) do 
  begin 
    // using a timeout interval so the loop conditions can still be checked periodically
    case MsgWaitForMultipleObjects(1, hTimer, False, 1000, QS_ALLINPUT) of
      WAIT_OBJECT_0:
      begin
        ProcessFiles;
        SetWaitableTimer(hTimer[0], iDue, 0, nil, nil, False);
      end;
      WAIT_OBJECT_0+1: Self.ServiceThread.ProcessRequests(false);
    end;
  end;
  CancelWaitableTimer(hTimer[0]);
  CloseHandle(hTimer[0]);
end;

Answer 3

使用计时器来运行 ProcessFiles 而不是将其侵入主应用程序循环。然后 ProcessFiles 将在您想要的时间间隔内运行，消息将得到正确处理，不会占用 100 % CPU。

Answer 4

我在多线程应用程序中使用了 TTimer，但结果很奇怪，所以现在我使用事件。

while (fServer.ServerState = ssStarted) and (Self.Terminated = false) do
begin
  Self.ServiceThread.ProcessRequests(false);
  ProcessFiles;

  if ExitEvent.WaitFor(3000) <> wrTimeout then
    Exit;   
 end;

您使用

创建事件

ExitEvent := TEvent.Create(nil, False, False, '');

现在最后一件事是在服务停止的情况下触发事件。我认为服务的 Stop 事件是放置这个的正确位置。

ExitEvent.SetEvent;

我将此代码用于我的数据库连接池系统中的清理线程，但它也应该适用于您的情况。

Answer 5

您无需睡眠整整 3 秒即可保持较低的 CPU 使用率。即使像 Sleep(500) 这样的东西也应该让你的使用率保持在很低的水平（如果没有等待处理的消息，它应该很快通过循环并再次进入睡眠状态。如果你的循环需要几毫秒才能运行它仍然意味着你的线程大部分时间都在睡觉。

话虽如此，您的代码可能会从一些重构中受益。您说您不希望 ProcessRequests 阻止等待消息？该循环中唯一的另一件事是 ProcessFiles。如果这取决于正在处理的消息，那么为什么它不能阻塞？如果它不依赖于正在处理的消息，那么它可以拆分到另一个线程吗？ （之前通过计时器触发 ProcessFiles 的建议是一个很好的建议）。

Answer 6

使用一个 TEvent 来指示线程何时应该唤醒。然后阻止 tevent（如果您有多个事件要等待，请使用 Jeroen 所说的 waitformultiple）

Answer 7

不能将 ProcessFiles 移动到单独的线程吗？在您的 MainThread 中，您只需等待消息，当服务终止时，您终止 ProcessFiles 线程。