如何在C#的Parallel.ForEachAsync中调用事件且不阻塞UI

你遇到的核心问题是**Parallel.ForEachAsync的执行线程来自线程池，而UI控件仅允许在创建它的UI线程上更新**，直接在非UI线程触发进度更新事件，会引发跨线程操作UI的错误，或是因线程抢占导致UI阻塞。

关键原因 #

• Parallel.ForEachAsync会把任务分配到多个线程池线程并行执行，你的IncrementProgress事件用于更新UI进度条，但所有主流UI框架（WPF/WinForms等）都强制要求UI操作必须在UI线程完成。
• 即使把事件声明为async，事件的触发依然是在调用它的线程池线程上，事件处理逻辑若直接操作UI，还是会违反跨线程规则。

解决方案 #

1. 切换到UI线程执行更新

根据你使用的UI框架，选择对应的线程切换方式：

WPF 场景：
用Dispatcher将更新操作切换到UI线程：

await Parallel.ForEachAsync<Individual>(INDlist, new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount }, async (individual, token) =>
{
    if (Cancel) throw new OperationCanceledException("Interface cancelled by the user");
    await UpdateIndividualAsync(individual);
    // 切换到UI线程触发进度更新
    Application.Current.Dispatcher.InvokeAsync(() =>
    {
        IncrementProgress?.Invoke(this, EventArgs.Empty);
    });
});

WinForms 场景：
使用控件的Invoke方法判断并切换线程：

await Parallel.ForEachAsync<Individual>(INDlist, new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount }, async (individual, token) =>
{
    if (Cancel) throw new OperationCanceledException("Interface cancelled by the user");
    await UpdateIndividualAsync(individual);
    // 检查是否需要跨线程调用
    if (progressBar1.InvokeRequired)
    {
        progressBar1.Invoke(new Action(() => IncrementProgress?.Invoke(this, EventArgs.Empty)));
    }
    else
    {
        IncrementProgress?.Invoke(this, EventArgs.Empty);
    }
});

2. 限制并发量

Parallel.ForEachAsync默认并发量较高，会导致大量线程同时触发UI更新请求，加重UI线程负担。通过ParallelOptions限制最大并发数，避免UI线程被过度抢占：

var options = new ParallelOptions 
{ 
    MaxDegreeOfParallelism = Math.Min(Environment.ProcessorCount, 4) // 可根据实际运行情况调整
};
await Parallel.ForEachAsync(INDlist, options, async (individual, token) =>
{
    // 业务逻辑与线程切换代码同上
});

3. 优化事件触发频率

如果进度更新不需要实时触发，可以用Interlocked累加进度值，再让UI线程定时读取并更新，减少跨线程调用的次数，降低UI线程压力。

内容的提问来源于stack exchange，提问作者Mark Grecco