Comment fonctionne exactement AsParallel?

Question

Cela ne semble pas faire de squat pour le programme de test suivant. Est-ce parce que je teste avec une petite liste?

static void Main(string[] args)
{
    List<int> list = 0.UpTo(4);

    Test(list.AsParallel());
    Test(list);
}

private static void Test(IEnumerable<int> input)
{
    var timer = new Stopwatch();
    timer.Start();
    var size = input.Count();
    if (input.Where(IsOdd).Count() != size / 2)
        throw new Exception("Failed to count the odds");

    timer.Stop();
    Console.WriteLine("Tested " + size + " numbers in " + timer.Elapsed.TotalSeconds + " seconds");
}

private static bool IsOdd(int n)
{
    Thread.Sleep(1000);
    return n%2 == 1;
}

L'exécution des deux versions prend 4 secondes.

Answer 1

La tâche Parallel Library se préoccupe du type statique de la séquence. Cela devrait être IParallelEnumerable<T> pour que les opérations soient gérées par le TPL. Vous remettez la collection sur IEnumerable<T> lorsque vous appelez Test. Par conséquent, le compilateur résoudra .Where l'appel de la séquence à la méthode d'extension System.Linq.Enumerable.Where au lieu de la version parallèle fournie par la TPL.

Answer 2

(Mise à jour pour .NET4 puisque cette question occupe une place de choix dans une recherche Google pour AsParallel ())

Quelques changements seulement permettront à votre exemple de fonctionner comme je l'imagine, comme vous le souhaitiez.

Remplacez List<int> list = 0.UpTo(4); par var list = Enumerable.Range(0, 4);

Votre exemple fonctionnerait si vous ajoutiez une surcharge de fonction avec une signature prenant une requête ParallelQuery ...

    private static void Test(ParallelQuery<int> input)
    {
        var timer = new Stopwatch();
        timer.Start();

        int size = input.Count();
        if (input.Where(IsOdd).Count() != size / 2)
        {
            throw new Exception("Failed to count the odds");
        }
        timer.Stop();

        Console.WriteLine("Tested " + size + " numbers in " + timer.Elapsed.TotalSeconds + " seconds");
    }

Vous pouvez également utiliser la syntaxe LINQ ....

    private static void Test(ParallelQuery<int> list)
    {
        var timer = Stopwatch.StartNew();

        if ((from n in list.AsParallel()
             where IsOdd(n)
             select n).Count() != (list.Count() / 2))
        {
            throw new Exception("Failed to count the odds");
        }

        Console.WriteLine("Tested " + list.Count() + " numbers in " + timer.Elapsed.TotalSeconds + " seconds");
    }

J'espère que cela aide quelqu'un!

Answer 3

As Parallel fonctionne en plaçant vos données dans le ThreadPool. Aussi, combien de cœurs avez-vous? Si vous travaillez sur une seule machine principale, il vous faudra encore environ 4 secondes.