多线程 Delphi 7 App - 应用程序终止问题

Question

我有一个 TThread 的后代和一个对象列表，每个对象都有自己的此类线程的副本，以及使用 CreateEvent() API 创建的 Event 对象。

不同的对象通过事件触发相互交互。 IE。每个线程必须等到某个其他线程触发其事件。当然，有一个“主”线程，它永久工作，因此永远不会发生自阻塞。这个系统在每个对象的 Execute 方法结束前都可以正常工作。

当我尝试中断所有线程时出现问题，例如通过应用关闭。在这种情况下，我需要一些调用每个线程的 Terminate 方法的外部函数：

  for i := 0 to FLayers.Count - 1 do
  begin
    FLayers.Layer[i].FTerminating := true;
    f := true;
    while f do
    begin
      f := FLayers.Layer[i].IsActive;
      if f then
      begin
        Sleep(100);
        Application.ProcessMessages;
      end;
    end;
    FLayers.Layer[i].FTerminating := false;
  end;

此函数位于 Form.OnClose() 事件中。

问题是大约有两个线程正常终止，但其他所有线程都在 WaitForSingleObject() 调用中停止：

procedure TLayerThread.Execute;
begin
FLayer.FIsActive := true;
...............
repeat
 //
 if Terminated or
   FLayer.FTerminating or
   (FLayer.FEvent = INVALID_HANDLE_VALUE) then
   begin
     break;
   end;
 //
 Fres := WaitForSingleObject(FLayer.FEvent, 100); <<<<<<<<<<<<<<<<<<<<<<<<
until Fres <> WAIT_TIMEOUT;
...........
FLayer.FIsActive := false;
end;

所有线程都只是停止（挂起）在线。上面标记，尽管设置了超时值。

有什么想法吗？

我正在使用 Delphi 7 和 Win XP。

提前致谢。

跟进--

我发现问题在 Execute() 方法中的 Synchronize() 调用中得到解决。我不明白这里有什么问题。 Synchronize() 调用通常的东西，比如视觉控件更新等等。

正如调试器所示，我的线程中没有一个挂在某个 WaitForSingleObject() 调用上，但这不是我在 Execute() 方法中用来协调不同线程的方法，而是另一个调用。我可以假设它在这里：

class procedure TThread.Synchronize(ASyncRec: PSynchronizeRecord);
.................
        LeaveCriticalSection(ThreadLock);
        try
          WaitForSingleObject(SyncProc.Signal, INFINITE);<<<<<<<<<<<<<<<<<<<<<<
        finally
          EnterCriticalSection(ThreadLock);
        end;
..................

有没有人可以告诉我我的代码有什么问题？我从来没有听说过不允许在 Execute() 方法中调用 Synchronize()...

Answer 1

您应该使用 WaitForMultipleObjects 而不是 WaitForSingleObject 无限超时并等待两个事件，您的 FLayer.FEvent 和第二个终止事件。

AFAIR 你必须为每个进程创建一个终止事件。 如果 WaitForMultipleObjects 返回终止事件的 ID，则退出循环。

在 OnClose() 方法中，您必须简单地通知所有终止事件。