PLINQ + LINQ = NRE？答案

【问题标题】：PLINQ + LINQ = NRE?PLINQ + LINQ = NRE？
【发布时间】：2023-03-26 02:23:01
【问题描述】：

运行以下代码时出现随机 NRE 的原因是什么？鉴于results 已初始化，如何在lambda 中将t 设为null？

var results = new List<Result>();

for (int i = 0; i < 100; i++)
{
    Parallel.For((index) =>
        {
            results.Add(Result.Create(...));    
        });

    results = results.Where(t => t.IsValid).ToList(); // NRE here due to t is null!

}

【问题讨论】：

您的示例无法编译并且是错误的。有一个Parallel.For 没有集合。

标签： c# linq nullreferenceexception plinq

【解决方案1】：

List<> 不是线程安全的。您正在从多个线程添加元素。如果你真的想使用它：

lock (results)
{
    results.Add(Result.Create(...));
}

请注意，您的示例是错误的...编译和运行的内容是：

var results = new List<Result>();

Parallel.For(0, 100, index =>
{
    lock (results)
    {
        results.Add(Result.Create(...));
    }
});

results = results.Where(t => t.IsValid).ToList(); // NRE here due to t is null!

或更好

var results = new List<Result>();

Parallel.For(0, 100, index =>
{
    var result = Result.Create(...);

    lock (results)
    {
        results.Add(result);
    }
});

results = results.Where(t => t.IsValid).ToList(); // NRE here due to t is null!

这样result的创建就不会阻塞List<>的写入:-)否则代码是没用的，它会被顺序执行。

【讨论】：

或者干脆var results = Enumerable.Range(0, 100).AsParallel().Select(i => Result.Create(...)).Where(t => t.IsValid).ToList()
@sloth 是的，如果您尝试参加其中一项必须节省字节数的比赛，或者您在混淆方面排名:-) 但我确实认为这里至少有区别... Parallel.For 知道数字的范围，所以它有 Length 信息，而 Enumerable.Range(0, 100).AsParallel() 不知道它。不知道这个信息是不是真的用了。
没错，如果需要，您可以使用var results = Enumerable.Range(0, 100).ToList().AsParallel()... 对其进行优化，以便默认分区程序可以更好地分配工作负载。
锁定这里本质上是将代码转换为顺序的。最好使用不需要任何锁定的 ConcurrentQueue。
您可能还想使用ConcurrentBag<T>，因为它针对这种情况进行了优化。