erstellen, neue Themen oder bekommen mehr Arbeit für Themen

Question

ich ein Programm habe ich die Erstellung (in C#) und ich sehe zwei Ansätze ..

1) Ein Job-Manager, der für eine beliebige Anzahl von X-Threads wartet bis zum Ende, wenn sie fertig sind es das nächste Stück Arbeit bekommt und erstellt einen neuen Thread und gibt es, dass die Brocken

oder

2) Wir X Threads erstellen sie jedem ein Stück Arbeit zu beginnen, geben, und wenn Ein Thread beendet einen Chunk und fragt den Jobmanager nach mehr Arbeit. Wenn es keine Arbeit mehr gibt, schläft es und fragt dann erneut, wobei der Schlaf immer länger wird.

Dieses Programm wird ein Lauf und fertig, so könnte ich sehen, dass es in einen Dienst verwandelt, der ständig nach mehr Jobs sucht.

Jeder Chunk besteht aus einer Reihe von Daten-IDs, einem Aufruf an die Datenbank, um einige Informationen zu erhalten oder eine Operation für die Daten-ID auszuführen, und dann Schreiben in die Datenbank-Information über die Daten-ID.

Answer 1

Vorausgesetzt, Sie sind sich der zusätzlichen Vorsichtsmaßnahmen bewusst, die bei Multithread-Datenbankoperationen zu beachten sind, klingt es, als würden Sie zwei verschiedene Szenarien beschreiben. Im ersten Fall laufen mehrere Threads, und sobald ALLE fertig sind, wird nach neuen Arbeiten gesucht. In der zweiten haben Sie mehrere Threads ausgeführt und ihre Operationen sind vollständig parallel. Ihre Umgebung bestimmt den richtigen Ansatz. Wenn es etwas gibt, das all die Arbeit in den verschiedenen Threads bindet, wo zusätzliche Arbeit nicht fortgesetzt werden kann, bis alle fertig sind, dann mit dem ersteren. Wenn sie sich nicht sehr beeinflussen, gehen Sie mit letzterem.

Answer 2

Anstatt eine eigene Lösung zu erstellen, sollten Sie sich die Klasse ThreadPool im .NET-Framework ansehen. Sie könnten die QueueUserWorkItem Methode verwenden. Es sollte genau das tun, was Sie erreichen wollen.

Answer 3

Die zweite Option ist nicht wirklich richtig, da die Schlafzeit immer länger wird bedeutet, dass Sie diese Threads unnötigerweise blockieren.

Stattdessen sollten Sie eine gepoolte Gruppe von Threads wie die zweite Option haben, aber sie verwenden WaitHandles, um auf Arbeit zu warten und ein Producer/Consumer-Muster zu verwenden. Wenn der Produzent anzeigt, dass es Arbeit gibt, sendet er ein Signal an einen Verbraucher (es wird einen Manager geben, der bestimmt, welcher Thread die Arbeit erhält und dann diesen Thread signalisiert), der aufwacht und zu arbeiten beginnt.

Möglicherweise möchten Sie in der Parallel Task Library nachsehen. Es ist jetzt in der Betaversion, aber wenn Sie es benutzen können und es sich gut anfühlen, würde ich es empfehlen, da es Ihnen eine Menge davon (und viel besser, unter Berücksichtigung der Anzahl der Kerne auf einer Maschine, der optimale Anzahl von Threads, etc, etc).

Answer 4

Die frühere Lösung (spawn einen Thread für jede neue Arbeit), ist einfacher zu programmieren, und nicht so schlecht, wenn die Arbeitseinheiten groß genug sind.

Die zweite Lösung (Thread-Pool, mit einer Warteschlange der Arbeit), ist komplizierter zu codieren, unterstützt aber kleinere Arbeitseinheiten.