Pipes zu mehreren Anwendungen gleichzeitig

[Neutral General]

Hi,

Ich versuche gerade mehrere Pipes zu mehreren Anwendungen parallel zu betreiben. Genauer starte ich ein Programm einige male und will zu jeder Instanz Pipes haben.

In der Theorie funktioniert das bei mir. Allerdings verliere ich die Verbindung zu den Pipes der 1. Anwendung wenn ich die zweite mit Pipes starte.

Habe eine Klasse, mit einer Methode namens Execute, die dieses Programm startet und Pipes zu dieser installiert. In Execute gibts dann eine While Schleife, die solange Daten bis der gestartete Prozess beendet wurde.

Ich poste mal meine Methode. Ist etwas gekürzt. Soll ja nur veranschaulichen wie ichs mache. Wenn weitere Informationen nötig sind, werde ich diese noch posten.

Delphi-Quellcode:

procedure TPipe.DoExecute;
var sui: TStartupInfo;
    pi: TProcessInformation;
begin
  // Pipes erstellen
  
  // StartupInfo einstellen

    CreateProcess(nil,PChar(cmdline),nil,nil,true,CREATE_DEFAULT_ERROR_MODE or PROFILE_USER or CREATE_NEW_CONSOLE or NORMAL_PRIORITY_CLASS,nil,nil,sui,pi);
    if pi.hProcess <> 0 then
    begin
      while WaitForSingleObject(pi.hProcess) <> WAIT_OBJECT_0 do
      begin
        ReadPipeData;
        Application.ProcessMessages;
        if FTerminate then  
          TerminateProcess(pi.hProcess,Cardinal(-1));
      end;    
    end;
end;

Das Problem ist eben, dass (scheinbar) die Schleife abbricht, bzw das DoExecute der ersten TPipe abgebrochen wird (?!) wenn eine zweite TPipe DoExecute ausführt. Ich erhalte keine Daten mehr. Die Verbindung scheint irgendwie abzubrechen. Ich aber nicht genau was geschieht. Das ist durch Debuggen nicht rauszufinden.

Muss man bei dem, was ich machen will irgendwas beachten oder mache ich sonst irgendwas falsch? Jedes TPipe(.DoExecute) für sich funktioniert wunderbar.

Es handelt sich übrigens um die plink.exe von Putty, falls diese Information wichtig sein sollte.

Gruß
Neutral General

[SirThornberry]

Application.Processmessages ist eben etwas anderes als mit Threads. Folgendes machst du:

Delphi-Quellcode:

start_prog(1);
while (pipe1) do
begin
  //mache irgendwas
end;

wenn du bei "mach irgendwas" jetzt das nächste startest sieht das ganze so aus:

Delphi-Quellcode:

start_prog(1);
while (pipe(1)) do
begin
  start_prog(2);
  while (pipe(2)) do
  begin
    //mache irgendwas
  end;
  //mache irgendwas
end;

[Neutral General]

Ok und was kann ich da machen?

Ich habe schon TThreads anstelle der while Schleife benutzt. Also so:

Delphi-Quellcode:

CreateProcess(nil,PChar(cmdline),nil,nil,true,CREATE_DEFAULT_ERROR_MODE or PROFILE_USER or CREATE_NEW_CONSOLE or NORMAL_PRIORITY_CLASS,nil,nil,sui,pi);
if pi.hProcess <> 0 then
begin
  Thread := TPipeThread.Create(true);
  try
    Thread.Pipe := Self;
    Thread.ProcessHandle := pi.hProcess;
    Thread.Execute;
  finally
    Thread.Free;
  end;
  TerminateProcess(pi.hProcess,Cardinal(-1));
end;

procedure TPipeThread.Execute;
begin
  while (WaitForSingleObject(ProcessHandle,1) <> WAIT_OBJECT_0) and (not Pipe.FTerminate) do
  begin
    Synchronize(Pipe.ReadPipeData);
    Application.ProcessMessages;
  end; 
end;

Das Ergebnis war allerdings das Gleiche.. Oder ist daran auch etwas falsch? Muss ich es ganz anders machen?

[SirThornberry]

Du erstellst zurzeit einen Thread aber lässt diesen nicht laufen. Durch den direkten Aufruf von Execute rufst du zwar eine Methode des Threadobjectes auf aber eben aus dem Hauptthread heraus (ist als würdest du irgend eine andere Funktion aufrufen).
Anstelle des Aufrufes von Execute musst du den Thread einfach mit Resume wieder los laufen lassen (schließlich hast du ihn suspended gestartet).
Allerdings hast du da noch einen Denkfehler drin. Denn bei resume hält der hauptthread nicht an sondern läuft weiter und arbeitet dann das Thread.Free ab was den Thread der ja grad erst losläuft schon wieder beendet.

Mach es also lieber so:

Delphi-Quellcode:

Thread := TPipeThread.Create(true); 
Thread.Pipe := Self; 
Thread.ProcessHandle := pi.hProcess; 
Thread.FreeOnTerminate = TRUE;
Thread.resume;

[Neutral General]

Hey danke!

Hast mir sehr geholfen :)