Wie wird Multi-Thread in C# verwendet?

Question

In meinem Projekt muss ich viel in einer foreach-Schleife tun, die ich 6-7 Stunden warten muss.

zum Beispiel: Ich habe 80 docs => ca. 8 Stunden überprüfen

foreach (var doc in docs) 
{ 
    bool valid = checkIsValid(doc); // about 2 min per doc 
    if (vaid) 
    { 
     doThing(doc); // about 5 min per doc 
    } 
    else 
    { 
     delete(doc); // about 20s per doc 
    } 
} 

Also, ich betrachten kann ich diese Dinge in der gleichen Zeit überprüfen, die ich viele Ressourcen verwendet nicht, wenn der Lauf über dem Code. Und ich finde, C# hat eine Multithread-Funktion (ich weiß nicht, was es bieten kann).

Kann ich es in meinem Projekt verwenden? Wie benutze ich es in meinem Projekt?

ideal: 80 Dokumente werden zur gleichen Zeit eingecheckt und die foreach-Schleife wird beendet, wenn 80 Threads gestorben sind.

foreach (var doc in docs) 
{ 
    //new thread start 
    bool valid = checkIsValid(doc); // about 2 min per doc 
    if (vaid) 
    { 
     doThing(doc); // about 5 min per doc 
    } 
    else 
    { 
     delete(doc); // about 20s per doc 
    } 
    //thread die 
} 

Answer 1

Haben Sie sich Parallel.ForEach angesehen? Ihr Code würde wie folgt aussehen:

Parallel.ForEach(docs, doc => { 
    if (checkIsValid(doc)) 
     doThing(doc); 
    else 
     delete(doc); 
}); 

Answer 2

es mehr Möglichkeiten gibt, Concurrency in C# zu erreichen, aber die Zeit, die von jedem Verfahren genommen, hängt von der Anzahl des Kerns Sie haben. 'Parallel.ForEach' ist eine Option und wahrscheinlich der einfachste Weg, um zu erreichen, aber beachten Sie, dass es versuchen wird, Ihre Arbeitsaufgabe wo möglich zu brechen und die Ausführung zu beschleunigen.

Der folgende Code soll Multithreading haben, aber seien Sie vorsichtig 80 Threads könnten ein Overkill sein. So erstellen Aufgaben (Threads) unter gebührender Berücksichtigung

foreach (var doc in docs) 
{ 
    //new thread start 
    bool valid = checkIsValid(doc); // about 2 min per doc 
    if (vaid) 
    { 
     Task.Factory.StartNew(() => doThing(doc); 
    } 
    else 
    { 
     delete(doc); // about 20s per doc 
    } 
    //thread die 
} 

Aufgaben im Rahmen arbeiten 4 und höher