Hallo,

ich habe folgendes Thema : Ich möchte von verschiedenen Quellen (kommt von verschiedenen Threads) Daten in eine DB schreiben, allerdings über eine einzige DB-Verbindung in einem anderen Thread (keiner davon ist der main thread).
Die soll in Intervallen erfolgen, sagen wir 5 Minuten (ist nicht zeitkritisch). Das hessit x thread senden Daten an den DB-Thread und der schreibt alle 5 Minuten das ganze Geraffel in die DB.
Jetzt meint mein Arbeitskollege, dass es da sowas wie eine thread queue oder Stack gibt, was genau für sowas da ist.

Hat da einer mehr Informationen ? Er wusste es aus dem Stehgreif gerade auch nicht und ich hab auch auf die Schnelle nichts gefunden.

Danke schonmal

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

markieren

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) .

Ich hab's wohl gefunden, er meinte wahrscheinlich TThreadedQueue<T>. Lese gerade ein wenig darüber

Sehr gut möglich. Das scheint ja genau das von mir beschriebene bereits selbst zu erledigen, nur halt mit einem TMonitor statt einer TCriticalSection.