Wie multi-threading mein Code mehrere Dateien gleichzeitig zu verarbeiten, durch die gleiche Funktion?

Question

ich die unten Routine bin mit einer Gruppe von Videos aus einem Verzeichnis zu verarbeiten:

AllVideos = new List<MyVideo>(); 

for (int i = 0; i < AllVideosFileNames.Length; i++) 
{ 
    MyVideo CurrentVid = new MyVideo(AllVideosFileNames[i], false); // constructor (loads the video to the system) 
    CurrentVid.PopulateAllFrames(); // Method that takes forever 
    CurrentVid.PopluateTestFrames(); // Method that takes less than forever 
    CurrentVid.NormalizeTestFrames(); // Method that takes some time 
    AllVideos.Add(CurrentVid); // Add finished object to my results container 
} 

Ich mag mehrere Videos gleichzeitig verarbeiten, parallel dazu, und Zeit sparen. Ich habe versucht, dies zu tun:

for (int i = 0; i < AllVideosFileNames.Length; i++) 
{ 
    Thread TempThread = new Thread(() => 
    { 
     MyVideo CurrentVid = new MyVideo(AllVideosFileNames[i], false); 
     CurrentVid.PopulateAllFrames(); 
     CurrentVid.PopluateTestFrames(); 
     CurrentVid.NormalizeTestFrames(); 
     AllVideos.Add(CurrentVid); 
    }); 
    TempThread.Start(); 
} 

Allerdings führt dies so schnell und tut buchstäblich nichts. Mit nichts meine ich, wenn ich durch den Code gehe, AllVideos ist leer, wenn die Schleife beendet wird.

Irgendwelche Ideen für ein besseres Design? oder eine Reparatur? Bitte und danke.

Answer 1

Vielleicht in TPL und/oder PLINQ. Wissen Sie über ?

Wie wäre:

AllVideos = AllVideosFileNames 
    .AsParallel() 
    .Select(fileName => GetVideo(filename)) 
    .ToList(); 

Wo GetVideo(filename) wie folgt definiert ist:

private MyVideo GetVideo(string filename) 
{ 
    MyVideo currentVid = new MyVideo(filename, false); 
    currentVid.PopulateAllFrames(); 
    currentVid.PopluateTestFrames(); 
    currentVid.NormalizeTestFrames(); 
    return currentVid; 
} 

Introduction to PLINQ für weitere Informationen.

Answer 2

Sie könnten versuchen, Parallel.ForEach zu verwenden. Es wird warten, bis der letzte Thread seine Ausführung, bevor Sie fortfahren beendet ist:

Parallel.ForEach(AllVideosFileNames, item => 
{ 
    MyVideo CurrentVid = new MyVideo(item, false); 
    CurrentVid.PopulateAllFrames(); 
    CurrentVid.PopluateTestFrames(); 
    CurrentVid.NormalizeTestFrames(); 
    AllVideos.Add(CurrentVid); 

}); 

Haftungsausschluss:

Wie bereits erwähnt und wieder von Dmitry Bychenko zu Aufmerksamkeit brachte die ListAllVideos speichern nicht Thema ist. Vielleicht möchten Sie Sperren in Betracht ziehen:

Parallel.ForEach(AllVideosFileNames, item => 
{ 
    MyVideo CurrentVid = new MyVideo(item, false); 
    CurrentVid.PopulateAllFrames(); 
    CurrentVid.PopluateTestFrames(); 
    CurrentVid.NormalizeTestFrames(); 
    lock (AllVideos) 
    { 
     AllVideos.Add(CurrentVid); 
    }  
});