MultiThreading

[Uwe Raabe]

Zitat von QuickAndDirty:

Ist das nicht ein Problem?
Beim Zugriff auf die MyList aus dem GUI thread heraus, würde schließlich im der GUI Thread angehalten werden(freeze), um auf die Fertigstellung des Futures zu warten.

Das ist offenbar so gewollt:

Zitat von DerMondistunsereSonne:

Und zu guter Letzt: Wenn in dem Form die Liste verwendet wird, soll geschaut werden, ob sie sich noch im Aufbau befindet, dann warten, sonst benutzen.

Mit ein klein wenig mehr Aufwand und Umbau ließe sich das aber auch ohne Freeze realisieren. Ob das bei den genannten 5 Sekunden nötig ist, kann sicher diskutiert werden.

[DerMondistunsereSonne]

Ähm ja, ist kein richtiger Freeze, wenn die Liste nicht aufgebaut wäre, würde die Verarbeitung sie aufbauen müssen. Es ist also nur eine Teilaufgabe und die muss immer vollständig abgeschlossen sein, bevor etwas es weiter geht.

@Uwe Hast du etwas Code, damit man den Aufwand ggf. abschätzen kann?

[QuickAndDirty]

Zitat von Uwe Raabe:

Mit ein klein wenig mehr Aufwand und Umbau ließe sich das aber auch ohne Freeze realisieren. Ob das bei den genannten 5 Sekunden nötig ist, kann sicher diskutiert werden.

so hätte ich es gemacht

Delphi-Quellcode:

myform.OnClick(Sender:tObject);
Bgein
  MyGUIListview.enabled := false;
  MYGUiAnyIndicator.visibe := true; // Anzeige Animation im Hauptthread das die Liste aktualisiert wird.
  
  TThread.CreateAnonymousThread(
      procedure
      Begin
        var data:Tarray<TMyItemdataRec> := LoadDataForaShitLoadOfTime; // das dauert.

        //laden fertig ? ok call back in den GUI Thread mit ForceQueue,
        // es kann sein dass der Thread schneller fertig ist als die GUI
        // braucht um die liste disabled neu zu zeichnen und ich mag
        // es in der richtigen Reienfolge wegen BeginUpdate udn EndUpdate
        // daher ForceQueue;
        TThreading.ForceQueue(nil,
          Procedure
          begin
            MyGUIListview.BeginUpdate;
            MyGUIListview.clear;
            For Var i:integer := 0 to high(data) do
              AddTMyListview(data[i]);
            MyGUIListview.Enabled := true;
            MyGUIListview.EndUpdate;
            MYGUiAnyIndicator.visible := false;
          end // procedure
        )//TThreading.ForceQueue(nil,
      end // procedure
  ).Start; // TThread.CreateAnonymousThread(
end;//myform.OnClick(Sender:tObject);

[QuickAndDirty]

Und wenn man Feedback und Fehlerbehandlung braucht so

Delphi-Quellcode:

Type 
TResultData = Record
  Success:boolean;
  Error:String;
  Data:Tarray<TMyItemdataRec>;  
end;

myform.OnClick(Sender:tObject);
Bgein
  MyGUIListview.enabled := false;
  MYGUiAnyIndicator.visibe := true; // Anzeige Animation im Hauptthread das die Liste aktualisiert wird.
  
  TThread.CreateAnonymousThread(
      procedure// ThreadProcedure
      Begin
        var aResult:TResultData := LoadDataForaShitLoadOfTime; // das dauert.
        If aResult.Success then
        Begin

          //laden fertig ? ok call back in den GUI Thread mit ForceQueue,
          // es kann sein dass der Thread schneller fertig ist als die GUI
          // braucht um die liste disabled neu zu zeichnen und ich mag
          // es in der richtigen Reienfolge wegen BeginUpdate udn EndUpdate
          // daher ForceQueue;
          TThreading.ForceQueue(nil,
            Procedure //ForceQueue
            begin
              If aResult.Success then
              Begin
                MyGUIListview.BeginUpdate;
                MyGUIListview.clear;
                For Var i:integer := 0 to length(aResult.data)-1 do
                  AddTMyListview(aResult.data[i]);
                MyGUIListview.Enabled := true;
                MyGUIListview.EndUpdate;
                MYGUiAnyIndicator.visible := false;
              end //If aResult.Success then
              else
              Begin
                Log(' LoadDataForaShitLoadOfTime:'+aResul.error);
                MyGUIListview.Enabled := true;
                MYGUiAnyIndicator.visible := false;             
                ShowMessage(aResul.error);  
              end //else If aResult.Success then
            end // procedure //ForceQueue
          )//TThreading.ForceQueue(nil,
      end // procedure// ThreadProcedure
  ).Start; // TThread.CreateAnonymousThread(
end;//myform.OnClick(Sender:tObject);

[Uwe Raabe]

Zitat von DerMondistunsereSonne:

@Uwe Hast du etwas Code, damit man den Aufwand ggf. abschätzen kann?

Klar. Man muss dazu nur das Future publizieren:

Delphi-Quellcode:

unit uMyList;

interface

function MyList: TStringList;
function MyListFuture: IFuture<TStringList>;

implementation

uses
  System.Threading;

var
  InternalFuture: IFuture<TStringList>;
  InternalList: TStringList;

function MyList: TStringList;
begin
  Result := InternalFuture.Value;
end;

function MyListFuture: IFuture<TStringList>;
begin
  Result := InternalFuture;
end;

initialization
  InternalList := TStringList.Create;
  InternalFuture := TTask.Future<TStringList>(
    function: TStringList
    begin
      Result := InternalList;
      for var I := 1 to 10000000 do
        Result.Add(I.ToString);
    end);
finalization
  InternalList.Free;
  InternalList := nil;
end;

Bei der Verwendung prüft man dann den Status des Future auf Completed und reagiert entsprechend.

Alternativ würde es hier auch genügen lediglich den TTaskStatus öffentlich zu machen. Dann muss aber System.Threading eh schon in der uses-Anweisung stehen. Das Future bietet zudem noch die Möglichkeit des Cancel.

Angenommen die Bearbeitung erfolgt auf einen Button-Click. Dann würde ich den Button mit einer TAction mit einem entsprechenden Execute-Event verbinden (sollte übrigens eh schon so sein). Im OnUpdate könnte dann sowas stehen:

Delphi-Quellcode:

begin
  (Sender as TAction).Enabled := (MyListFuture.Status = TTaskStatus.Completed);
end;

Damit lässt sich der Button nur klicken, wenn die Liste fertig ist,

Dort ließe sich auch eine Behandlung für Canceled bzw. Exception unterbringen.

[DerMondistunsereSonne]

Danke, das scheint überschaubar. Mal sehen wie weit ich das umsetze.

[QuickAndDirty]

Zitat von Uwe Raabe:

Das Future bietet zudem noch die Möglichkeit des Cancel.

Ernsthaft kann man von außen einen laufenden Thread (oder eben future) beenden????

Also nicht von innen durch abfragen von "Terminated"?

[Uwe Raabe]

Zitat von QuickAndDirty:

Ernsthaft kann man von außen einen laufenden Thread (oder eben future) beenden????

Also nicht von innen durch abfragen von "Terminated"?

Nein, das Cancel setzt auch nur ein Flag. Innerhalb der Future-Routine muss man das schon noch prüfen und entsprechend berücksichtigen. Das Future bietet halt ein einheitliches Interface dafür.