1

当我尝试使用 Plinq (Parallel linq) 进行对象收集时，我遇到了一个基本问题，我观察到 Plinq 与正常操作在执行时间方面没有太大差异。任何人都可以检查我的代码并告诉我为什么会这样。我已经在 i7 处理器中运行了这段代码。

class Program
{
    static void Main(string[] args)
    {
        new Program().Plinq();
        new Program().linq();
        Console.ReadLine();
    }

    void Plinq()
    {

        DateTime startTime = DateTime.Now;

        var query1 = (from port in new XpressEntities().Portfolios.Take(1000000)
                      select new port { PortId = port.PORT_ID, CFAC = port.CFAC }).ToList<port>();

        query1.AsParallel().Where(e => e.PortId == 0);
        TimeSpan ts = DateTime.Now.Subtract(startTime);
        Console.WriteLine("Time Elapsed: {0} Seconds:MilliSeconds in Paralel mode", ts.Seconds + ":" + ts.Milliseconds);

    }

    void linq()
    {

        DateTime startTime = DateTime.Now;

        var query1 = (from port in new XpressEntities().Portfolios.Take(1000000)
                      select new port { PortId = port.PORT_ID, CFAC = port.CFAC }).ToList<port>();

        query1.Where(e => e.PortId == 0);
        TimeSpan ts = DateTime.Now.Subtract(startTime);
        Console.WriteLine("Time Elapsed: {0} Seconds:MilliSeconds in Normal mode", ts.Seconds + ":" + ts.Milliseconds);

    }

}
class port
{
    public int PortId { get; set; }
    public string CFAC { get; set; }
}

上面代码的结果是

经过时间：6:411 秒：并行模式下的毫秒数

经过的时间：6:68 秒：正常模式下的毫秒数

4

1 回答 1

1

  • Where() 返回一个 IEnumerable 并且不会导致查询被评估。您需要明确评估答案（例如，使用 ToList()）。

  • 必须考虑启动线程的一些开销，因此您的工作负载必须花费足够的时间来执行，以便您可以观察到差异。除非评估标准的成本很高，否则对适合内存的列表进行过滤可能还不够。

  • 使用 System.Diagnostics.Stopwatch 类进行测量；它具有更好的精度。

于 2012-02-02T17:17:19.437 回答