How exactly does AsParallel work?

c# .net plinq
ripper234 picture ripper234 · Nov 28, 2009 · Viewed 13.9k times · Source

It doesn't seem to do squat for the following test program. Is this because I'm testing with a small list?

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;
}

Both versions take 4 seconds to run.

Answer

mmx picture mmx · Nov 28, 2009

Task Parallel Library cares about the static type of the sequence. It should be IParallelEnumerable<T> for the operations to be handled by the TPL. You are casting the collection back to IEnumerable<T> when you call Test. Therefore, the compiler will resolve .Where call on the sequence to System.Linq.Enumerable.Where extension method instead of the parallel version provided by the TPL.

Related questions

Max Degree of Parallelism for AsParallel()

While using Parallel.ForEach we have the option to define the Parallel options and set the Max Degree of Parallelism like : Parallel.ForEach(values, new ParallelOptions {MaxDegreeOfParallelism = number}, value = > { // Do Work }) But while doing PLINQ like: Tabel.AsEnumberable() .AsParallel() .…

Read More
Exactly what is PLINQ?

PLINQ was added in the .NET 4.0 Framework as an extension to LINQ. What is it? What problems does it solve? When is it appropriate and when not?

Read More
How to make an HTTP POST web request

Canonical How can I make an HTTP request and send some data using the POST method? I can do a GET request, but I have no idea of how to make a POST request.

Read More