Thema: Thread Queue

Einzelnen Beitrag anzeigen

Der schöne Günther

Registriert seit: 6. Mär 2013
6.110 Beiträge
 
Delphi 10 Seattle Enterprise
 
#2

AW: Thread Queue

  Alt 20. Dez 2020, 21:09
Wahrscheinlich meinte er/sie System.Classes.TThreadList? Wenn ja, glaube ich nicht dass man das heute noch verwenden sollte - Das ist ja ein uraltes Ding aus der Zeit von vor Generics und arbeitet mit rohen Zeigern.

Mach dir doch einfach ein
Delphi-Quellcode:
type
  TData = record
    (...)
  end;

  IDataQueue = interface
    procedure addData(const data: TData);
    function retrieveAllAndClear(): TArray<TData>;
  end;
Implementieren kann man IDataQueue wie man lustig ist, beispielsweise mit einer einfachen TList<TData> und bei den beiden Aufrufen gesichert über eine TCriticalSection Dein Thread kann dann z.B. immer zehn Sekunden schlafen (oder darauf warten dass mindestens x Einträge in der Liste sind weil es sich erst dann lohnt), mit retrieveAllAndClear() alles aus der Liste holen und wegschreiben.

Keep it simple, stupid


PS: Wenn der Thread wirklich keine andere Aufgabe hat als etwas asynchron wegzuschreiben könnte man auch noch einmal hinterfragen ob der überhaupt notwendig ist. Du könntest vielleicht ebenso einfach aus verschiedenen Threads Daten an dein IDateQueue anhängen und es selbst schaut nach jedem Aufruf von addData(..) ob genug Kram vorhanden ist und speichert den Kram dann selbst asynchron weg, z.B. einfach TTask.Run(saveDataToDatabase) .

Geändert von Der schöne Günther (20. Dez 2020 um 21:12 Uhr)
  Mit Zitat antworten Zitat