Parallel Programming Library: Reihenfolge von Tasks (Priorisierung)

[karlkoch]

Ok, bisher bin ich mit eigenen Entwicklungen gut gefahren, war jedoch der Hoffnung, meine Implementierungen schrittweise durch "native" Unterstützungen zu ersetzen. Schade, dann ist die PPL immer noch nicht für meine Zwecke geeignet.

Viele Grüße,

karlkoch

[Mavarik]

Zitat von karlkoch:

Ok, bisher bin ich mit eigenen Entwicklungen gut gefahren, war jedoch der Hoffnung, meine Implementierungen schrittweise durch "native" Unterstützungen zu ersetzen. Schade, dann ist die PPL immer noch nicht für meine Zwecke geeignet.

Wenn man als Werkzeug nur einen Hammer hat, sehen alle Ziele wie ein Nagel aus...

Sicherlich kann man viele Hintergrundverarbeitung mit der PPL lösen, aber wie immer bei Lösungen nach dem Motto "One fits all", gibt es in der Regel eine
spezielle Lösung für ein Problem, dass der Anforderung besser gerecht wird.

Die PPL ist sehr gut für "shot and forget" geeignet. Spätestens, wenn es sich nicht um "Schön-Wetter-Code" handelt und ggf. Fehlermeldung/Exceptions zu erwarten sind,
muss man sich auch mit der PPL schon Gedanken machen.

Also bei Hintergrundverarbeitungen z.b. in Apps für iOS & Android, bei denen möglichst alles was nicht auf die UI zugreift, im Hintergrund ausgeführt werden sollte, ist die
PPL sehr hilfreich bis zu - ohne geht es kaum.

Daher - immer das richtige Werkzeug für das zu lösende Problem verwenden!

Mavarik

[karlkoch]

Hallo,

an sich bin ich mit der PPL zufrieden, es fehlen nur Kleinigkeiten, um mein Vorhaben mit der Library umzusetzen.

Eigentlich ist das Problem gar nicht mehr die fehlende Priorisierung, sondern die Möglichkeit, die maximale Anzahl gleichzeitig abzuarbeitender Tasks zu beschränken. Meine Idee ist, durch einen eigenen "Scheduler" die vielen Tasks zunächst in einer eigener Queue zu sammeln und immer nur dann an die PPL zu übergeben (ITask.Start), wenn aktuell nicht mehr als X Tasks ausgeführt werden. Gerade bei Festplatten- oder Datenbankzugriffen darf es nicht zu viele gleichzeitige Tasks geben, wobei TThreadPool.SetMaximumWorkerThreads keine Abhilfe schafft, weil dieser Wert an die CPU-Kerne gebunden ist.

Leider scheitert mein Vorhaben aktuell daran, dass ich es nicht schaffe, auf saubere Art und Weise extern über die Fertigstellung eines Tasks informiert zu werden, damit ich die nächsten Tasks rausschicken kann (egal ob ein Task ausgeführt, abgebrochen oder durch einen Fehler beendet wurde). Interessant sieht für mich TTask.ProcessCompleteEvents aus, weil das immer am Ende eines Tasks aufgerufen wird, allerdings verhindert TTask eine Ableitung, sodass ich diese Methode überschreiben könnte.

Oder hat jemand einen anderen Ansatz für mich?

Viele Grüße,

karlkoch

[Sinspin]

Hallo.
Warum willst du das Event ableiten? Schreib doch einfach einen Handler dafür. In dem machst du nichts anderes als einen Zähler zu erhöhen. Beim Start eines neuen Tasks erhöst du einen anderen Zähler.
Du startest dann einfach weitere Tasks bis dir der Abstand zwischen den beiden Zählern zu groß wird. Bzw. wieder neue wenn der Abstand wieder passt.

[karlkoch]

Zitat von Sinspin:

Warum willst du das Event ableiten? Schreib doch einfach einen Handler dafür.

Die PPL ruft diesen Handler, soweit ich das überblicke und testen konnte, jedoch nicht immer auf, z.B. nicht, wenn ein Task noch vor dem Start abgebrochen wird (oder auf dem Weg zwischen Start und Verarbeitung im Workerthread). Sobald ein Scheduler einen Tasks an die PPL schickt (ITask.Start), müsste garantiert werden, dass in jedem Fall ein Handler für diesen Task aufgerufen wird, was meiner Meinung nach im Moment nicht der Fall ist.

Viele Grüße,

karlkoch

[karlkoch]

Hallo,

meine aktuelle Lösung sieht folgendermaßen aus:

Delphi-Quellcode:

TMyTask = class(TAbstractTask);

InternalTask := TMyTask.IInternalTask(Task);
InternalTask.AddCompleteEvent(
  procedure (Task: ITask)
  begin
    // Task ist fertig
  end
);

Das funktioniert, egal ob ein Task abgebrochen oder verarbeitet wurde, aber schöner fände ich es, wenn die PPL so ein Event öffentlich unterstützen würde, oder ich übersehe etwas.

Viele Grüße,

karlkoch

[himitsu]

Du kannst doch nachgucken?

* Schauen was AddCompleteEvent macht, also wo das Event gespeichert wird.
* wenn da dort mehreres registriert werden kann, schauen ob es auch eine globale Registrierung gibt
* dann gucken wo es aufgerufen wird und ob es dort auch einen Aufruf eines globalen Events gibt, bzw. ob diese Stelle überschreibbar ist

...
Am Ende ist TTask.ProcessCompleteEvents virtual und kann somit überschrieben/erweitert werden.


Und ich hoffe dein Task läuft nicht schon, denn wenn er gerade fertig wird, während du dein Event registriert, kann es passieren, dass dein Event nicht aufgerufen wird.
[EDIT] OK, falls ich nicht nochwas übersehn hab, dann sollte es doch nicht passieren.