Как именно работает AsParallel?

Похоже, он не подходит для следующей тестовой программы. Это потому, что я тестирую с небольшим списком?

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

Обе версии запускаются за 4 секунды.


.net c# plinq
person ripper234    schedule 28.11.2009    source источник
comment
Как вы получили Upto, метод расширения?   -  person thewpfguy    schedule 28.01.2014

Ответы (3)


arrow_upward
24
arrow_downward

Библиотека параллельных задач заботится о статическом типе последовательности. Это должно быть IParallelEnumerable<T> для операций, которые будут обрабатываться TPL. Вы возвращаете коллекцию обратно в IEnumerable<T>, когда вызываете Test. Таким образом, компилятор разрешит .Where вызов последовательности в метод расширения System.Linq.Enumerable.Where вместо параллельной версии, предоставляемой TPL.

person mmx    schedule 28.11.2009

arrow_upward
5
arrow_downward

(Обновление для .NET4, так как этот вопрос занимает довольно высокое место в поиске Google для AsParallel())

Всего несколько изменений позволят вашему примеру работать так, как вы ожидали.

Изменить List<int> list = 0.UpTo(4); на var list = Enumerable.Range(0, 4);

Ваш пример будет работать, если вы добавите перегрузку функции с подписью, которая принимает 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");
    }

В качестве альтернативы вы можете использовать синтаксис 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");
    }

Надеюсь, это поможет кому-то!

person AlfredBr    schedule 21.03.2011

arrow_upward
2
arrow_downward

Поскольку Parallel работает, помещая ваши материалы в ThreadPool. И сколько у тебя ядер? Если вы работаете на одноядерной машине, для ее запуска все равно потребуется около 4 секунд.

person JeffreyABecker    schedule 28.11.2009