Thread Queue

[MyRealName]

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

[Der schöne Günther]

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

Delphi-Quellcode:

IDataQueue

wie man lustig ist, beispielsweise mit einer einfachen

Delphi-Quellcode:

TList<TData>

und bei den beiden Aufrufen gesichert über eine

Delphi-Quellcode:

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

Delphi-Quellcode:

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

Delphi-Quellcode:

IDateQueue

anhängen und es selbst schaut nach jedem Aufruf von

Delphi-Quellcode:

addData(..)

ob genug Kram vorhanden ist und speichert den Kram dann selbst asynchron weg, z.B. einfach

Delphi-Quellcode:

TTask.Run(saveDataToDatabase)

.

[MyRealName]

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

[Der schöne Günther]

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