TParallel for: wie Schleife abbrechen?

[Harry Stahl]

Leider sind die Informationen zur TParallel-Library noch sehr spärlich.

Wie kann man eine TParallel.for schleife eigentlich vorzeitig abbrechen?
Also abbrechen, bevor alle Iterationen durchlaufen sind?

Ein "break" scheint es nicht zu geben.

[Sir Rufo]

Du musst dir ein zentrales Break selber bauen ...

Delphi-Quellcode:

procedure Foo;
var
  LBreak: Boolean;
  LValue: Integer;
begin
  LBreak := False;
  LValue := 0;
  TParallel.&For( 1, 1000,
      procedure( L: Integer )
    begin
      if not LBreak
      then
        begin
          Inc( LValue );
          LBreak := L = 100;
        end;
    end );
  Writeln( LValue );
end;

[Harry Stahl]

OK, das geht, aber offensichtlich wird die For Schleife dann trotzdem die vorgesehene Anzahl durchlaufen, nur, dass eben nichts abgearbeitet wird.

Gibt es da wirklich nichts anderes?

Mal Frage am Rande: Warum verwendest Du immer "Tparallel.&For", statt "TParallel.For"?

In der Hilfe steht es auch mit "&", warum eigentlich?

[Sir Rufo]

Ja, da gibt es doch ein Break (mir war doch auch so )

Delphi-Quellcode:

procedure Foo;
var
  LValue: Integer;
begin
  LValue := 0;
  TParallel.&For( 1, 1000,
      procedure( L: Integer; S: TParallel.TLoopState )
    begin
      if not S.ShouldExit
      then
        begin
          Inc( LValue );
          if L = 500
          then
            S.Break;
        end;
    end );
  Writeln( LValue );
end;

Da wird auf jeden Fall früher abgebrochen, allerdings laufen ein paar Tasks noch durch die Schleife. Sieht man schön, wenn man das ausführt

Delphi-Quellcode:

procedure Foo;
var
  LValue: Integer;
begin
  LValue := 0;
  TParallel.&For( 1, 1000,
      procedure( L: Integer; S: TParallel.TLoopState )
    begin
//      if not S.ShouldExit
//      then
//        begin
          Inc( LValue );
          if L = 500
          then
            S.Break;
//        end;
    end );
  Writeln( LValue );
end;

Bei mir kommt dann regelmäßig 529 heraus.

[Sir Rufo]

Zitat von Harry Stahl:

Mal Frage am Rande: Warum verwendest Du immer "Tparallel.&For", statt "TParallel.For"?

In der Hilfe steht es auch mit "&", warum eigentlich?

Weil for ein reserviertes Wort ist. Und um das so zu deklarieren muss man ein & davor setzen.

Delphi-Quellcode:

TFoo = class
  procedure &For;
  procedure &Type;
  procedure &Begin;
  procedure &End;
  procedure &Class;
  procedure &procedure;
end;

[Harry Stahl]

Super, so was hatte ich gesucht, aber leider nicht gefunden.

[Sir Rufo]

Zitat von Harry Stahl:

Super, so was hatte ich gesucht, aber leider nicht gefunden.

Steht aber in der Doku http://docwiki.embarcadero.com/Libra....TParallel.For

Delphi-Quellcode:

class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorEvent): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorEvent; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorStateEvent): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorStateEvent; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorEvent): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorEvent; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorStateEvent): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Integer; AIteratorEvent: TIteratorStateEvent; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer>): TLoopResult; overload; static; inline;
class function &For(ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer>; APool: TThreadPool): TLoopResult; overload; static; inline;
{ da } class function &For(ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer, TLoopState>): TLoopResult; overload; static; inline;
{ da } class function &For(ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer, TLoopState>; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(AStride, ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer>): TLoopResult; overload; static; inline;
class function &For(AStride, ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer>; APool: TThreadPool): TLoopResult; overload; static; inline;
{ da } class function &For(AStride, ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer, TLoopState>): TLoopResult; overload; static; inline;
{ da } class function &For(AStride, ALowInclusive, AHighInclusive: Integer; const AIteratorEvent: TProc<Integer, TLoopState>; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorEvent64): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorEvent64; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorStateEvent64): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorStateEvent64; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorEvent64): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorEvent64; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorStateEvent64): TLoopResult; overload; static; inline;
class function &For(Sender: TObject; AStride, ALowInclusive, AHighInclusive: Int64; AIteratorEvent: TIteratorStateEvent64; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64>): TLoopResult; overload; static; inline;
class function &For(ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64>; APool: TThreadPool): TLoopResult; overload; static; inline;
{ da } class function &For(ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64, TLoopState>): TLoopResult; overload; static; inline;
{ da } class function &For(ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64, TLoopState>; APool: TThreadPool): TLoopResult; overload; static; inline;
class function &For(AStride, ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64>): TLoopResult; overload; static; inline;
class function &For(AStride, ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64>; APool: TThreadPool): TLoopResult; overload; static; inline;
{ da } class function &For(AStride, ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64, TLoopState>): TLoopResult; overload; static; inline;
{ da } class function &For(AStride, ALowInclusive, AHighInclusive: Int64; const AIteratorEvent: TProc<Int64, TLoopState>; APool: TThreadPool): TLoopResult; overload; static; inline;

Und wenn ich nicht weiß, was TLoopState oder TLoopResult ist, und die Doku nicht weiterweiß, dann einfach ein STRG-Klick auf das Unbekannte und direkt im Quelltest nachschauen

BTW: TIteratorStateEvent /TIteratorStateEvent64 haben auch noch den TLoopState

[Harry Stahl]

Ich muss gestehen, das hatte ich gesehen, aber das Gewünschte nicht gefunden (ist ja auch ein wenig unübersichtlich...).

Was soll eigentlich s.shouldexit bewirken? Wenn man das aufruft, hat das anscheinend keine Auswirkungen?

In System.Threading gibt es das da:

Delphi-Quellcode:

class function TParallel.ForWorker...

 while (I < ToExclusive) and ((SharedFlags.LoopStateFlags = []) or not SharedFlags.ShouldExit) do

EDIT: Oh, jetzt gesehen, dass Shoudexit einen Wert zurückgibt, nicht setzt. Wäre aber gut, wenn man die Rückgabe von SharedFlags.ShouldExit mit True hinkriegen könnte, dann wir die While-Schleife unterbrochen

[Sir Rufo]

Öhm, das ist doch offensichtlich und darum habe ich den Code doch auch in 2 Variationen eingestellt. Einmal mit Abfrage s.ShouldExit und einmal ohne. Bei beiden wird die Verarbeitung der Tasks vorzeitig abgebrochen, allerdings sind einige Tasks schon über dem PointOfNoReturn und werden trotzdem noch durch die Worker-Threads verarbeitet.

Und genau für diese durchgerutschten Tasks frage ich den LoopStateTLoopState ab. Und wenn man vorher ein TLoopState.Break aufgerufen hat, dann liefert TLoopState.ShouldExit ganz lapidar ein True .

Genau das wollen wir doch haben ... oder nicht?

[himitsu]

Man hätte es aber auch einfacher implementieren können, indem man z.B. auch auf Abort reagiert und dann die anderen Schleifen-Threads abbricht (Break-State setzt).

Aber wenn man in dem For-Event etwas längeres macht, oder eine Schleife, dann sollte man da natürlich auch den State prüfen.