数据并行和任务并行中的潜在缺陷

项目
05/09/2023

在许多情况下，与普通的顺序循环相比，Parallel.For 和 Parallel.ForEach 可以显著提升性能。但是，对循环进行并行化的工作增加了复杂性，可能会导致在顺序代码中出现不常见或根本不会遇到的问题。本主题列出了一些在编写并行循环时要避免的做法。

不要假定并行的速度始终更快

在某些情况下，并行循环可能比它等效的顺序循环的运行速度更慢。基本的经验法则是具有较少迭代和快速用户委托的并行循环未必会快很多。但是，由于性能会涉及到很多因素，因此我们建议始终衡量实际的结果。

避免写入共享内存位置

在顺序代码中，从静态变量或类字段中读取或写入静态变量或类字段的情况很常见。但是，每当多个线程同时访问此类变量时，则很有可能会出现争用条件。即使可以使用锁来同步对变量的访问，但同步开销可能会对性能造成损害。因此，我们建议尽可能地避免在一个并行循环中访问共享状态，或至少限制对共享状态的访问。为此，最好使用 Parallel.For 和 Parallel.ForEach 的重载，以便在循环执行期间使用 System.Threading.ThreadLocal<T> 变量存储线程本地状态。有关详细信息，请参阅如何：编写具有线程局部变量的 Parallel.For 循环和如何：使用分区本地变量编写 Parallel.ForEach 循环。

避免过度并行化

通过使用并行循环，将会产生对源集合进行分区和同步工作线程的开销成本。计算机上的处理器数量进一步限制了并行化的优点。仅在一个处理器上运行多个受计算限制的线程时，速度并不会得到提升。因此，必须要小心，不要对循环进行过度并行化。

在嵌套的循环中，最有可能发生过度并行化的情况。在大多数情况下，除非满足以下一个或多个条件，否则最好仅对外部循环进行并行化：

已知内部循环非常长。
正在对每个订单执行开销极大的计算。（示例中所示的操作开销不大。）
已知目标系统有足够的处理器来处理通过并行处理生成的线程数。

在所有情况下，确定最佳查询形式的最好方法是进行测试和测量。

避免调用非线程安全方法

如果从并行循环中写入非线程安全实例方法，可能会导致出现程序可能检测到也可能检测不到的数据损坏。还可能会导致异常。在下面的示例中，多个线程尝试同时调用 FileStream.WriteByte 方法，类并不支持这样做。

FileStream fs = File.OpenWrite(path);
byte[] bytes = new Byte[10000000];
// ...
Parallel.For(0, bytes.Length, (i) => fs.WriteByte(bytes[i]));

Dim fs As FileStream = File.OpenWrite(filepath)
Dim bytes() As Byte
ReDim bytes(1000000)
' ...init byte array
Parallel.For(0, bytes.Length, Sub(n) fs.WriteByte(bytes(n)))

限制调用线程安全方法

.NET 中的大多数静态方法是线程安全的，并且可以同时从多个线程中调用。但是，即使在这些情况下，所涉及到的同步也可能会导致查询速度大幅度下降。

注意

可以自行对此进行测试，具体方法是在查询中插入一些 WriteLine 调用。尽管出于演示目的，在文档示例中使用了此方法，但除非必要，否则不要在并行循环中使用它。

注意线程关联问题

某些技术（例如，单线程单元 (STA) 组件的 COM 互操作性、Windows 窗体以及 Windows Presentation Foundation (WPF)）具有要求代码在特定线程上运行的线程关联限制。例如，在 Windows 窗体和 WPF 中，只能在创建控件的线程上访问该控件。举例来说，这意味着，除非将线程调度器配置为仅将工作安排在 UI 线程上，否则你将无法从并行循环中更新列表控件。有关详细信息，请参阅指定同步上下文。

在由 Parallel.Invoke 调用的委托中等待时请谨慎使用

在某些情况下，任务并行库将对任务进行内联操作，这意味着它将在当前正在执行的线程上的任务上运行。（有关详细信息，请参阅任务计划程序。）此性能优化在某些情况下可能会导致死锁。例如，两个任务可能运行相同的委托代码，该代码在事件发生时将发出信号，然后等待另一个任务发出信号。如果在相同线程上将第二个任务内联为第一个，并且第一个任务进入等待状态，则第二个任务将永远无法发出其事件信号。为了避免发生这种情况，可以在等待操作上指定超时，或使用显式线程构造函数来帮助确保一个任务无法阻止另一个任务。

不要假定 ForEach、For 和 ForAll 的迭代始终并行执行

请务必注意，For、ForEach 或 ForAll 循环中的各个迭代可能会（但不需要）并行执行。因此，应避免编写任何依赖于迭代并行执行的正确性或依赖于按任何特定顺序执行迭代的代码。例如，此代码有可能会死锁：

ManualResetEventSlim mre = new ManualResetEventSlim();
Enumerable.Range(0, Environment.ProcessorCount * 100)
    .AsParallel()
    .ForAll((j) =>
        {
            if (j == Environment.ProcessorCount)
            {
                Console.WriteLine("Set on {0} with value of {1}",
                    Thread.CurrentThread.ManagedThreadId, j);
                mre.Set();
            }
            else
            {
                Console.WriteLine("Waiting on {0} with value of {1}",
                    Thread.CurrentThread.ManagedThreadId, j);
                mre.Wait();
            }
        }); //deadlocks

Dim mres = New ManualResetEventSlim()
Enumerable.Range(0, Environment.ProcessorCount * 100) _
.AsParallel() _
.ForAll(Sub(j)

            If j = Environment.ProcessorCount Then
                Console.WriteLine("Set on {0} with value of {1}",
                                  Thread.CurrentThread.ManagedThreadId, j)
                mres.Set()
            Else
                Console.WriteLine("Waiting on {0} with value of {1}",
                                  Thread.CurrentThread.ManagedThreadId, j)
                mres.Wait()
            End If
        End Sub) ' deadlocks

在此示例中，一个迭代设置一个事件，而所有的其他迭代则等待该事件。在设置事件的迭代完成之前，任何等待迭代均无法完成。但是，在设置事件的迭代有机会执行之前，等待迭代可能会阻止用于执行并行循环的所有线程。这将导致死锁 – 设置事件的迭代将永不会执行，并且等待迭代将永远不会醒来。

具体而言，并行循环的一个迭代绝不应该等待循环的另一个迭代来继续执行。如果并行循环决定按相反的顺序安排迭代，则会发生死锁。

避免在 UI 线程上执行并行循环

务必要使应用程序的用户界面 (UI) 保持响应状态。如果操作包含足够的工作来保证并行化，则可能不应在 UI 线程上运行。相反，而是应卸载要在后台线程上运行的该操作。例如，如果要使用并行循环来计算随后应在 UI 控件中呈现的某些数据，则应考虑在任务实例内执行循环，而不是直接在 UI 事件处理程序中执行。只有先当核心计算完成后，才应将 UI 更新封送回 UI 线程。

如果确实要在 UI 线程上运行并行循环，请当心，避免从循环内更新 UI 控件。如果尝试从在 UI 线程上执行的并行循环内更新 UI 控件，将可能会导致状态损坏、异常、更新延迟甚至死锁，具体将取决于 UI 更新的调用方式。在下面的示例中，在所有的迭代完成之前，并行循环将阻止它在其上执行的 UI 线程。不过，如果循环的迭代是对后台线程运行（就像 For 一样），调用 Invoke 可能会导致将消息提交到 UI 线程，并阻止等待处理相应消息。由于 UI 线程受阻止而无法运行 For，因此消息永远无法得到处理，且 UI 线程死锁。

private void button1_Click(object sender, EventArgs e)
{
    Parallel.For(0, N, i =>
    {
        // do work for i
        button1.Invoke((Action)delegate { DisplayProgress(i); });
    });
}

Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click

    Dim iterations As Integer = 20
    Parallel.For(0, iterations, Sub(x)
                                    Button1.Invoke(Sub()
                                                       DisplayProgress(x)
                                                   End Sub)
                                End Sub)
End Sub

下面的示例演示如何通过在任务实例内运行循环来避免死锁。循环不会阻止 UI 线程，并且消息可得到处理。

private void button1_Click(object sender, EventArgs e)
{
    Task.Factory.StartNew(() =>
        Parallel.For(0, N, i =>
        {
            // do work for i
            button1.Invoke((Action)delegate { DisplayProgress(i); });
        })
         );
}

Private Sub Button2_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click

    Dim iterations As Integer = 20
    Task.Factory.StartNew(Sub() Parallel.For(0, iterations, Sub(x)
                                                                Button1.Invoke(Sub()
                                                                                   DisplayProgress(x)
                                                                               End Sub)
                                                            End Sub))
End Sub

通过