Postupy: Jak vytvořit jednoduchou paralelní ForEach smyčku

Tento příklad znázorňuje použití Parallel.ForEach smyčky k zpřístupnění paralelnosti dat nad jakýmkoliv System.Collections.IEnumerable nebo System.Collections.Generic.IEnumerable<T> zdrojem dat.

Poznámka
Tato dokumentace používá lambda výrazy k definování delegátů v PLINQ.Pokud nejste obeznámeni s lambda výrazy v jazyce C# nebo Visual Basic, pokračujte na Lambda výrazy v PLINQ a TPL.

Příklad

' How to: Write a Simple Parallel.ForEach Loop
' IMPORTANT!!!: Add reference to System.Drawing.dll
Imports System.Threading
Imports System.Threading.Tasks
Imports System.Drawing

Module ForEachDemo

    Sub Main()
        ' A simple source for demonstration purposes. Modify this path as necessary.
        Dim files As String() = System.IO.Directory.GetFiles("C:\Users\Public\Pictures\Sample Pictures", "*.jpg")
        Dim newDir As String = "C:\Users\Public\Pictures\Sample Pictures\Modified"
        System.IO.Directory.CreateDirectory(newDir)

        ' Method signature: Parallel.ForEach(IEnumerable<TSource> source, Action<TSource> body)
        ' Be sure to add a reference to System.Drawing.dll.
        Parallel.ForEach(files, Sub(currentFile)
                                    ' The more computational work you do here, the greater 
                                    ' the speedup compared to a sequential foreach loop.
                                    Dim filename As String = System.IO.Path.GetFileName(currentFile)
                                    Dim bitmap As New System.Drawing.Bitmap(currentFile)

                                    bitmap.RotateFlip(System.Drawing.RotateFlipType.Rotate180FlipNone)
                                    bitmap.Save(System.IO.Path.Combine(newDir, filename))

                                    ' Peek behind the scenes to see how work is parallelized.
                                    ' But be aware: Thread contention for the Console slows down parallel loops!!!

                                    Console.WriteLine("Processing {0} on thread {1}", filename, Thread.CurrentThread.ManagedThreadId)
                                    'close lambda expression and method invocation
                                End Sub)


        ' Keep the console window open in debug mode.
        Console.WriteLine("Processing complete. Press any key to exit.")
        Console.ReadKey()
    End Sub
End Module

namespace ForEachDemo
{
    using System;
    using System.Drawing; // requires system.Drawing.dll
    using System.IO;
    using System.Threading;
    using System.Threading.Tasks;

    class SimpleForEach
    {
        static void Main()
        {
            // A simple source for demonstration purposes. Modify this path as necessary.
            string[] files = System.IO.Directory.GetFiles(@"C:\Users\Public\Pictures\Sample Pictures", "*.jpg");
            string newDir = @"C:\Users\Public\Pictures\Sample Pictures\Modified";
            System.IO.Directory.CreateDirectory(newDir);

            //  Method signature: Parallel.ForEach(IEnumerable<TSource> source, Action<TSource> body)
            Parallel.ForEach(files, currentFile =>
            {
                // The more computational work you do here, the greater 
                // the speedup compared to a sequential foreach loop.
                string filename = System.IO.Path.GetFileName(currentFile);
                System.Drawing.Bitmap bitmap = new System.Drawing.Bitmap(currentFile);

                bitmap.RotateFlip(System.Drawing.RotateFlipType.Rotate180FlipNone);
                bitmap.Save(System.IO.Path.Combine(newDir, filename));

                // Peek behind the scenes to see how work is parallelized.
                // But be aware: Thread contention for the Console slows down parallel loops!!!
                Console.WriteLine("Processing {0} on thread {1}", filename,
                                    Thread.CurrentThread.ManagedThreadId);

            } //close lambda expression
                 ); //close method invocation

            // Keep the console window open in debug mode.
            Console.WriteLine("Processing complete. Press any key to exit.");
            Console.ReadKey();
        }
    }
}

A ForEach smyčky pracuje stejně jako For smyčky. Zdrojová kolekce je rozdělená na oddíly a práce je naplánována do více vláken v závislosti na systémovém prostředí. Čím více procesorový systém je, tím rychleji běží paralelní metody. Pro některé zdrojové kolekce může být rychlejší sekvenční smyčka. Toto je závislé na velikosti zdroje a druhu práce, která je vykonávána. Další informace o výkonuPotenciální nástrahy datového a funkčního paralelismu

Další informace o paralelní smyčky naleznete Postupy: Psát jednoduché smyčky Parallel.For.

Použití ForEach -Obecný kolekce, můžete pomocí Cast<TResult> rozšíření metody převést na obecnou kolekci kolekce, jak ukazuje následující příklad:

Parallel.ForEach(nonGenericCollection.Cast(Of Object), _
                 Sub(currentElement)
                     ' ... work with currentElement
                 End Sub)

Parallel.ForEach(nonGenericCollection.Cast<object>(),
    currentElement =>
    {
    });

Paralelní LINQ (PLINQ) můžete použít také ke zpracování parallelize IEnumerable<T> datových zdrojů. PLINQ vám umožní použítí deklarativního syntaxu dotazu k vyjádření chování smyčky. Další informace naleznete v tématu Paralelní LINQ (PLINQ).

Probíhá kompilace kódu

• Zkopírujte a vložit tento kód do Visual Studio Konzolového projektu 2010.

• Přidejte odkaz do System.Drawing.dll

• Stisknutí klávesy F5

Viz také

Koncepty

Datový paralelismus (Task Parallel Library)

Paralelní programování v rozhraní .NET Framework

Paralelní LINQ (PLINQ)