Ist es die richtige Implementierung?

Ein wichtiger Faktor, der bei der Zuweisung von neuem Threads zu beachten ist, ist, dass das Betriebssystem eine Anzahl von logischen Entitäten zuweisen muss, damit dieser aktuelle Thread ausgeführt werden kann:

1. Thread-Kernel-Objekt - ein Objekt zur Beschreibung des Threads einschließlich des Kontexts des Threads, der CPU-Register usw.
2. Thread-Umgebungsblock - Für die Ausnahmebehandlung und lokalen Thread Speicher
3. Benutzermodus-Stack - 1 MB Stapel
4. Kernelmodus-Stack - Zum Übergeben von Argumenten vom Benutzermodus an den Kernel Modus

Ansonsten hängt die Anzahl der gleichzeitigen Threads , die ausgeführt werden können, von der Anzahl der Kerne ab, die Ihre Maschine packt, und das Erstellen einer Anzahl von Threads, die größer ist als die Anzahl der Kerne, die Ihre Maschine besitzt, verursacht Context Switching , die auf lange Sicht Ihre Arbeit verlangsamen können.

Also nach dem langen Intro, zu den guten Sachen. Eigentlich möchten wir die Anzahl der laufenden Threads begrenzen und sie so oft wie möglich wiederverwenden.

Für diese Art von Job würde ich mit TPL Dataflow , die auf dem Producer-Consumer -Muster basiert. Nur ein kleines Beispiel dafür, was getan werden kann:

Sie können jedes Block a ExecutionDataflowBlockOptions übergeben, was die Bounded Capacity (die Anzahl der Objekte im BufferBlock) und MaxDegreeOfParallelism begrenzen kann, wodurch der Block die maximale Anzahl von Nebenläufigkeiten angibt.

Es gibt ein gutes Beispiel hier , um Ihnen den Einstieg zu erleichtern .

Ich bin froh, dass Sie gefragt haben, weil Sie Recht haben in dem Sinne, dass - das ist nicht der beste Ansatz.

Das Konzept von Task sollte nicht mit einem Thread verwechselt werden. Ein Thread kann mit einem Koch in einer Küche verglichen werden, während ein Task ein von einem Kunden bestelltes Gericht ist. Sie haben eine Reihe von Köchen, und sie verarbeiten die Bestellungen in einer Bestellung (in der Regel FIFO). Ein Koch beendet ein Gericht und geht dann zum nächsten über. Das Konzept des Thread-Pools ist gleich. Sie erstellen eine Reihe von Aufgaben, die abgeschlossen werden müssen, aber Sie müssen keinen neuen Aufgaben zuweisen.

Ok, also die eigentlichen Bits dazu. Es gibt ein paar. Der erste ist ThreadPoll.QueueUserWorkItem . ( Ссылка ). Unter Verwendung der Parallel-Bibliothek kann auch Parallel.For verwendet werden, es erzeugt automatisch Threads basierend auf der Anzahl der tatsächlichen CPU-Kerne, die im System verfügbar sind.

Beachten Sie, dass es keine Garantie gibt, dass die von Parallel.For aufgerufene Methode der Reihe nach aufgerufen wird (0,1,2,3,4,5 ...). Die tatsächliche Reihenfolge hängt von der Ausführung ab.