Procedura: scrivere un ciclo Parallel.ForEach semplice

In questo esempio viene mostrato come utilizzare un ciclo Parallel.ForEach per applicare il parallelismo dei dati su qualsiasi origine dati System.Collections.IEnumerable o System.Collections.Generic.IEnumerable<T>.

Nota
Questa documentazione utilizza espressioni lambda per definire delegati in PLINQ.Se non si ha familiarità con le espressioni lambda in C# o Visual Basic, vedere Espressioni lambda in PLINQ e TPL.

Esempio

' 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();
        }
    }
}

Un ciclo ForEach funziona come un ciclo For. L'insieme di origine viene partizionato e il lavoro viene pianificato in più thread in base all'ambiente di sistema. Quanto maggiore è il numero di processori nel sistema, tanto più veloce sarà l'esecuzione del metodo in parallelo. Per alcuni insiemi di origine, a seconda della dimensione dell'origine e del tipo di lavoro eseguito, è possibile che un ciclo sequenziale sia più veloce. Per ulteriori informazioni sulle prestazioni, vedere Problemi potenziali nel parallelismo di dati e attività.

Per ulteriori informazioni sui cicli paralleli, vedere Procedura: scrivere un ciclo Parallel.For semplice.

Per utilizzare ForEach con un insieme non generico, è possibile utilizzare il metodo di estensione Cast<TResult> per convertire l'insieme in un insieme generico, come illustrato nell'esempio seguente:

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

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

È inoltre possibile utilizzare Parallel LINQ (PLINQ) per parallelizzare l'elaborazione delle origini dati IEnumerable<T>. PLINQ consente di utilizzare una sintassi di query dichiarativa per esprimere il comportamento dei cicli. Per ulteriori informazioni, vedere Parallel LINQ (PLINQ).

Compilazione del codice

• Copiare e incollare questo codice in un progetto di applicazione console di Visual Studio 2010 e premere F5.

• Aggiungere un riferimento a System.Drawing.dll

• Premere F5

Vedere anche

Concetti

Parallelismo dei dati (Task Parallel Library)

Programmazione parallela in .NET Framework

Parallel LINQ (PLINQ)