Delphi-Multi-Threading-Message-Schleife

Meine Anwendung hat mehrere threads:
1) Haupt-Thread
2) 2 Sub-Haupt-Threads (jeweils mit Message-Loop), wie unten gezeigt), das von TFQM
3) n Worker-Threads (einfache Schleife mit Sleep())

Mein problem ist, wenn ich in der Nähe meiner Anwendung, die Worker-Threads zu verwalten, um ordnungsgemäß zu beenden, aber 1 von den 2 Sub-Haupt-Threads hängt (nie beendet), wenn ich Frage WM_QUIT, um Sie zu schließen.

procedure ThreadProcFQM(P: Integer); stdcall;
var
  Msg: TMsg;
 _FQM: TFQM;
begin
  _FQM := Ptr(P);
  try
    _FQM.fHandle := AllocateHwnd(_FQM.WndProc);

    while GetMessage(Msg, 0, 0, 0) do
    begin
      TranslateMessage(Msg);
      DispatchMessage(Msg);
    end;

  finally
    DeallocateHWnd(_FQM.fHandle);
    SetEvent(_FQM.hTerminated);
  end;
end;
procedure TFQM.Stop;
begin
  PostMessage(fHandle, WM_QUIT, 0, 0);

  WaitForSingleObject(hTerminated, INFINITE);
  if hThread <> INVALID_HANDLE_VALUE then
  begin
    CloseHandle(hThread);
    hThread := INVALID_HANDLE_VALUE;
  end;
end;
InformationsquelleAutor Atlas | 2008-10-23
  1. 11

    Wenn ich zeigen kann, um einige Probleme in deinen code ...

    1) Du bist nicht prüfen Ausgabe von AllocateHwnd. Ja, wahrscheinlich wird es nie scheitern, aber trotzdem ...

    2) AllocateHwnd belogs von try..finally! Wenn es nicht gelingt, DeallocateHwnd sollte nicht aufgerufen werden.

    3) AllocateHwnd ist nicht threadsicher. Wenn Sie es aufrufen aus mehreren threads zur gleichen Zeit, die Sie ausführen können, in poblems. Lesen Sie mehr.

    Als Davy sagte, verwenden Sie MsgWaitForMultipleObjects anstatt versteckte Nachricht Fenster. Dann nutzen Sie PostThreadMessage Nachrichten zu senden-thread.

    Wenn ich einen Stecker für eine völlig freie Produkte - verwenden Sie meine OmniThreadLibrary statt. Viel einfacher als messing direkt mit Windows messaging.

    • Gabr, danke, aber deine lib ist nur begrenzt auf D2006+? Ich bin mit D7....
    • D2007+, eigentlich. Zeit für das upgrade, dann 🙂
    • Gabr, Ihr threading-Bibliothek sieht fantastisch aus - danke für den Hinweis it out. Oh, und ich würde sagen, Ihre Website ist "spartan", nicht hässlich.
    InformationsquelleAutor gabr
  2. 9

    Ich habe das gleiche problem, und ich fand heraus, dass ich sollte nicht erstellen Sie ein ausgeblendetes Fenster, nur um zu empfangen Nachrichten. Threads, die bereits über ein message-system.

    Ich denke, dass Sie bei der Erstellung einer windows-handle und speichern Sie es in fHandle, aber GetMessage überprüft Ihren thread (message-loop). Daher ist die Nachricht PostMessage(fHandle, WM_QUIT, 0, 0); nie erhielt durch die getmesssage.

    Können Sie Nachrichten an deinen thread mit PostThreadMessage, und in den Faden, den Sie verwenden GetMessage(CurrentMessage, 0, 0, 0). Der einzige wichtige Unterschied ist, dass Sie haben, um starten Sie den message loop aus deinem thread durch den Aufruf 

    PeekMessage(CurrentMessage, 0, WM_USER, WM_USER, PM_NOREMOVE);

    Sollten Sie mit diesem zu starten, als Ihr setup und starten Sie den loop.

    Der Grund, warum Sie beginnen sollten, mit das peek-Nachricht, um sicherzustellen, dass Nachrichten, die gesendet werden während der Initialisierung der threadprocedure nicht verloren gehen.

    Komisch ist, dass im moment ich kann nicht finden die Referenz, wo ich das gelernt, aber meine Vermutung ist, dass die newsgroup-community.

    • Ooops, sorry, mein erstes mal hier. Wusste nicht, über Kommentare.... Ich werde es einmal versuchen. Danke.
    • Davy hat Recht: PeekMessage sollte verwendet werden, um die Message Queue
    • Sie Lesen es auf der MSDN-Seite für PostThreadMessage. Sie empfehlen sogar mit der main-thread wartet auf ein Ereignis, das der thread untergeht, sobald er die Botschaft erstellt wurde.
    InformationsquelleAutor Davy Landman
  3. 7

    1) brauchen Sie nicht in AllocateHwnd in Ihrem thread. Ersten Aufruf von GetMessage erstellen eine eigene message-queue für diesen thread. Aber, um die Nachricht senden zu dem Thema, das Sie verwenden sollten, PostThreadMessage Funktion.

    Sich bewusst sein, dass im moment der Aufruf von PostThreadMessage die Warteschlange noch nicht erstellt werden konnte. Normalerweise verwende ich-Konstruktion:

    while not PostThreadMessage(ThreadID, idStartMessage, 0, 0) do
  Sleep(1);

    um sicherzustellen, dass die message-queue erstellt.

    2) Für die Kündigung thread-Schleife definiere ich meine eigene Nachricht:

      idExitMessage = WM_USER + 777; // you are free to use your own constant here

    3) Es gibt keine Notwendigkeit für separate Veranstaltung, da kann man Durchlaufen, thread-handle, um
    WaitForSingleObject-Funktion. So könnte der code Aussehen:

      PostThreadMessage(ThreadID, idExitMessage, 0, 0);
  WaitForSingleObject(ThreadHandle, INFINITE);

    Berücksichtigen, dass die ThreadID und ThreadHandle unterschiedliche Werte.

    4) So, Ihr ThreadProc Aussehen wird:

    procedure ThreadProcFQM; stdcall;
var
  Msg: TMsg;
begin
  while GetMessage(Msg, 0, 0, 0) 
    and (Msg.Message <> idExitMessage) do
  begin
    TranslateMessage(Msg);
    DispatchMessage(Msg);
  end;
end;
    • Danke, ich werde es einmal versuchen.
    • Wie wies darauf hin, unten, sollten Sie die Message-Queue mit PeekMessage: // Force Message Queue Erstellung von PeekMessage(Msg, 0, WM_USER, WM_USER, PM_NOREMOVE);
    InformationsquelleAutor
Schreibe einen Kommentar