AGB  ·  Datenschutz  ·  Impressum  







Anmelden
Nützliche Links
Registrieren
Zurück Delphi-PRAXiS Sprachen und Entwicklungsumgebungen Object-Pascal / Delphi-Language Variable eines Record geht beim Multithreading verloren

Variable eines Record geht beim Multithreading verloren

Ein Thema von j.zT · begonnen am 28. Nov 2024 · letzter Beitrag vom 28. Nov 2024
Antwort Antwort
j.zT

Registriert seit: 12. Nov 2024
2 Beiträge
 
#1

Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 12:05
Delphi-Version: 12 Athens
Hallo,
ich versuche mich gerade am Multithreading mit delphi und bin gerade auf ein seltsames Verhalten gestoßen, dass ich nicht verstehe.
Ich habe derzeit folgenden Code:

Delphi-Quellcode:
procedure TForm1.btnEventClick(Sender: TObject);
begin
  TMessageManagerClass.DefaultManager.SubscribeToMessage(MyMessage,
  procedure(const Sender: TObject; const M: System.Messaging.TMessage)
  var
    bstr : string;
    p : string;
    i : string;
  begin
    bstr := (TThread.CurrentThread.ThreadID = MainThreadID).ToString();

    p := MyMessage(M).Value.Str;
    i := MyMessage(M).Value.I.ToString();

// TThread.Queue(nil, procedure
// begin
// edtEvent.Text := p + i + '/' + bstr + '/' + (TThread.CurrentThread.ThreadID = MainThreadID).ToString();
// end);

    TThread.Queue(nil, procedure
    begin
      edtEvent.Text := MyMessage(M).Value.Str + MyMessage(M).Value.I.ToString() + '/' + bstr + '/' + (TThread.CurrentThread.ThreadID = MainThreadID).ToString();
    end);
  end);

  EventThread.Create();
end;
Delphi-Quellcode:
  MyRecord = record
    Str: string;
    I: Integer;
  end;

  MyMessage = class(TMessage<MyRecord>)
  end;

  EventThread = class(TThread)
  protected
    procedure Execute; override;
  end;

Delphi-Quellcode:
procedure EventThread.Execute;
var
  rec : MyRecord;
begin
  while True do
  begin
    rec.str := Chr(ord('a') + Random(26));
    rec.I := Random(9);

    TMessageManager.DefaultManager.SendMessage(self, MyMessage.Create(rec));

    Sleep(1000);
  end;
end;
Ich sehe in der Variable p, dass ein zufälliger Buchstabe in dem string steht. Wenn der Code dann aber im TThread.Queue ankommt, dann ist MyMessage(M).Value.Str = ''.
Wenn ich in TThread.Queue aber auf die Variable p direkt zugreife (siehe auskommentierter Code), dann ist der Char wie erwartet im edit zu sehen.

Kann mir jemand erklären, warum das so passiert?

Edit 1:
Ich habe das ganze mit Synchronize getestet. Hier ist es egal, ob ich den String in einer Variablen zwischenspeichere, oder direkt aus dem Record auslese. In beiden Fällen wird der Char in den Edit geschrieben.

Geändert von j.zT (28. Nov 2024 um 12:26 Uhr)
  Mit Zitat antworten Zitat
Benutzerbild von Uwe Raabe
Uwe Raabe

Registriert seit: 20. Jan 2006
Ort: Lübbecke
11.463 Beiträge
 
Delphi 12 Athens
 
#2

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 13:18
Der Parameter M ist innerhalb der anonymen Methode nur bis zu ihrem Ende gültig. Der Code im Queue-Aufruf findet aber später statt (bei Synchronize ist das nicht der Fall).

Wie du schon bemerkt hast, kannst du das über eine lokale Variable lösen, die dann auch innerhalb der anonymen Queue-Methode gültig ist. Das kann anstatt der einzelnen Variablen p und i auch eine Variable vom Typ MyRecord sein.

Delphi-Quellcode:
procedure TForm1.btnEventClick(Sender: TObject);
begin
  TMessageManagerClass.DefaultManager.SubscribeToMessage(MyMessage,
  procedure(const Sender: TObject; const M: System.Messaging.TMessage)
  var
    bstr : string;
    my: MyRecord;
  begin
    bstr := (TThread.CurrentThread.ThreadID = MainThreadID).ToString();

    my := MyMessage(M).Value;

    TThread.Queue(nil, procedure
    begin
      edtEvent.Text := my.Str + my.I.ToString + '/' + bstr + '/' + (TThread.CurrentThread.ThreadID = MainThreadID).ToString();
    end);

  end);

  EventThread.Create();
end;
Uwe Raabe
Certified Delphi Master Developer
Embarcadero MVP
Blog: The Art of Delphi Programming
  Mit Zitat antworten Zitat
Rollo62

Registriert seit: 15. Mär 2007
4.101 Beiträge
 
Delphi 12 Athens
 
#3

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 13:19
Erstmal, TMessageManager ist nicht threadsafe.
Wenn man was drumrum synchronisiert, zum Beispiel um das SendMessage, dann sollte es aber funktionieren.
  Mit Zitat antworten Zitat
Benutzerbild von Uwe Raabe
Uwe Raabe

Registriert seit: 20. Jan 2006
Ort: Lübbecke
11.463 Beiträge
 
Delphi 12 Athens
 
#4

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 13:49
Erstmal, TMessageManager ist nicht threadsafe.
Zumindest ist das aber so vorgesehen:
Delphi-Quellcode:
procedure TMessageManager.SendMessage(const Sender: TObject; AMessage: TMessage; ADispose: Boolean);
var
  Subscribers: TListenerList;
begin
  if AMessage = nil then
    raise Exception.CreateRes(@SArgumentInvalid);

  TMonitor.Enter(FListeners);
  try
    try
      if FListeners.TryGetValue(AMessage.ClassType, Subscribers) then
        Subscribers.SendMessage(Sender, AMessage);
    finally
      if ADispose then
        AMessage.Free;
    end;
  finally
    TMonitor.Exit(FListeners);
  end;
end;
Kannst du konkrete Fälle aufzeigen bei denen TMessageManager nicht thread-safe ist? (Ich will ja gar nicht ausschließen dass es die gibt.)
Uwe Raabe
Certified Delphi Master Developer
Embarcadero MVP
Blog: The Art of Delphi Programming
  Mit Zitat antworten Zitat
Rollo62

Registriert seit: 15. Mär 2007
4.101 Beiträge
 
Delphi 12 Athens
 
#5

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 14:30
Ja, ich benutze das auch mit Queue und Synchronize, das macht es ja threadsafe.
Warum es nicht threadsafe ist, da ist Dalija sehr stark der Meinung, dass es das auf gar keinen Fall ist,
und hat deshalb NxHorizon rausgebracht
https://en.delphipraxis.net/topic/42...&comment=37053

https://en.delphipraxis.net/topic/70...us-nx-horizon/

Das kommt so an mehreren Stellen und verschiedenen Threads, wird wohl was dran sein.
Ich habe jetzt explizit auch keine Probleme damit, aber synchronisiere auch auch alles, da wo es nötig ist.

Vermutlich ist gemeint, dass man sich von außen um die Synchronisation kümmern muss, und das nicht implizit in TMessage eigebaut ist.
  Mit Zitat antworten Zitat
j.zT

Registriert seit: 12. Nov 2024
2 Beiträge
 
#6

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 16:44
Der Parameter M ist innerhalb der anonymen Methode nur bis zu ihrem Ende gültig. Der Code im Queue-Aufruf findet aber später statt (bei Synchronize ist das nicht der Fall).

Wie du schon bemerkt hast, kannst du das über eine lokale Variable lösen, die dann auch innerhalb der anonymen Queue-Methode gültig ist. Das kann anstatt der einzelnen Variablen p und i auch eine Variable vom Typ MyRecord sein.

Delphi-Quellcode:
procedure TForm1.btnEventClick(Sender: TObject);
begin
  TMessageManagerClass.DefaultManager.SubscribeToMessage(MyMessage,
  procedure(const Sender: TObject; const M: System.Messaging.TMessage)
  var
    bstr : string;
    my: MyRecord;
  begin
    bstr := (TThread.CurrentThread.ThreadID = MainThreadID).ToString();

    my := MyMessage(M).Value;

    TThread.Queue(nil, procedure
    begin
      edtEvent.Text := my.Str + my.I.ToString + '/' + bstr + '/' + (TThread.CurrentThread.ThreadID = MainThreadID).ToString();
    end);

  end);

  EventThread.Create();
end;
Danke für die Antwort. Es macht Sinn, dass die Variable out of scope geht und gecleared wird. Dann macht für mich allerdings keinen Sinn, warum der Integer i weiterhin geschrieben werden kann.

Setzt Delphi strings auf '' wenn sie out of scope gehen und bei Integern wird nur der Speicher nur für Wiederverwendung freigegeben, aber nicht auf 0 gesetzt?
Wenn das Zutrifft, ist es dann einfach nur Zufall, dass der Speicher des Integer einfach nicht wiederverwendet wurde und deshalb die Zahl die gleiche ist?
  Mit Zitat antworten Zitat
TomyN

Registriert seit: 8. Nov 2006
Ort: Bayreuth
249 Beiträge
 
Delphi 10.3 Rio
 
#7

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 16:57
Genau. Gerade auch im Debugger 'halten' Variablen(-inhalte) manchmal länger als sie müssten.
Später dann auf einem Kundenrechner tun sie das dann plötzlich nicht mehr.
Thomas Neumann
Meine Projekte
www.satlive.audio
www.levelcheck.de
  Mit Zitat antworten Zitat
Benutzerbild von himitsu
himitsu

Registriert seit: 11. Okt 2003
Ort: Elbflorenz
44.098 Beiträge
 
Delphi 12 Athens
 
#8

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 19:04
Bzw. jetzt hat Emba gesagt, dass Variblen garnicht mehr so lange halten müssen, wie man denkt und wie bisher es "immer" war.

Ich würde ja den Thread zu suchen, aber ....
Neuste Erkenntnis:
Seit Pos einen dritten Parameter hat,
wird PoSex im Delphi viel seltener praktiziert.
  Mit Zitat antworten Zitat
Benutzerbild von Uwe Raabe
Uwe Raabe

Registriert seit: 20. Jan 2006
Ort: Lübbecke
11.463 Beiträge
 
Delphi 12 Athens
 
#9

AW: Variable eines Record geht beim Multithreading verloren

  Alt 28. Nov 2024, 21:58
Dann macht für mich allerdings keinen Sinn, warum der Integer i weiterhin geschrieben werden kann.

Setzt Delphi strings auf '' wenn sie out of scope gehen und bei Integern wird nur der Speicher nur für Wiederverwendung freigegeben, aber nicht auf 0 gesetzt?
Wenn das Zutrifft, ist es dann einfach nur Zufall, dass der Speicher des Integer einfach nicht wiederverwendet wurde und deshalb die Zahl die gleiche ist?
Nein. Was hier zum Tragen kommt nennt sich Variablenbindung anonymer Methoden (Stichwort Closure). Die Verwendung der Variablen innerhalb der anonymen Methode sorgt intern dafür, dass die Variable nicht wie üblich im lokalen Bereich der umgebenden Methode gespeichert wird, sondern in einem separaten Bereich, der im Scope der anonymen Methode(n) liegt.

In deinem Beispiel werden p und i im Closure erfasst weil sie als Variablen deklariert sind. Der Parameter wird zwar auch erfasst, ist aber eine Instanz einer TMessage-Klasse, die nach dem SendMessage wieder freigegeben wird. Daher enthält sie beim späteren Ausführen der Queue-Methode einen undefinierten Inhalt.
Uwe Raabe
Certified Delphi Master Developer
Embarcadero MVP
Blog: The Art of Delphi Programming
  Mit Zitat antworten Zitat
Themen-Optionen Thema durchsuchen
Thema durchsuchen:

Erweiterte Suche
Ansicht

Forumregeln

Es ist dir nicht erlaubt, neue Themen zu verfassen.
Es ist dir nicht erlaubt, auf Beiträge zu antworten.
Es ist dir nicht erlaubt, Anhänge hochzuladen.
Es ist dir nicht erlaubt, deine Beiträge zu bearbeiten.

BB-Code ist an.
Smileys sind an.
[IMG] Code ist an.
HTML-Code ist aus.
Trackbacks are an
Pingbacks are an
Refbacks are aus

Gehe zu:

Impressum · AGB · Datenschutz · Nach oben
Alle Zeitangaben in WEZ +1. Es ist jetzt 14:20 Uhr.
Powered by vBulletin® Copyright ©2000 - 2024, Jelsoft Enterprises Ltd.
LinkBacks Enabled by vBSEO © 2011, Crawlability, Inc.
Delphi-PRAXiS (c) 2002 - 2023 by Daniel R. Wolf, 2024 by Thomas Breitkreuz