ForEach-Object -Parallel嵌套foreach返回结果异常求助

你的代码出现随机计数差异，核心原因是多个并行线程同时修改同一个非线程安全的数组：

• $result.CSV是普通PowerShell数组，+=操作本质是创建新数组并替换原数组，这个过程不是原子操作。
• 当多个并行线程同时执行($using:result).CSV += ...时，会出现线程间操作冲突——比如线程A刚读取数组长度准备扩容，线程B已完成扩容并修改了引用，此时线程A的写入会覆盖线程B的结果，导致元素丢失。
• 单线程模式（-ThrottleLimit 1）下无并发冲突，结果稳定，但失去了并行处理的效率优势。

方案1：利用并行输出自动汇总（推荐） #

ForEach-Object -Parallel会自动收集每个线程的输出结果，无需共享变量修改，从根源规避竞态条件：

$contacts = 200001..200064
while(1){
    $resultCSV = foreach($contact in $contacts){
        $contacts | ForEach-Object -Parallel {
            # 直接输出字符串，而非修改共享变量
            "$($using:contact);$_"
        } -ThrottleLimit 30
    }
    $resultCSV.Count
}

该方案优势：

• 彻底解决并发修改问题，结果稳定
• 完整保留并行处理的效率
• 代码简洁，符合PowerShell管道设计理念

方案2：使用线程安全集合 #

如果必须依赖共享变量模式，可使用.NET的线程安全集合ConcurrentBag存储结果，它支持多线程安全添加元素：

$contacts = 200001..200064
while(1){
    # 初始化线程安全集合
    $result = [System.Collections.Concurrent.ConcurrentBag[string]]::new()
    foreach($contact in $contacts){
        $contacts | ForEach-Object -Parallel {
            # 使用Add方法安全添加元素
            ($using:result).Add("$($using:contact);$_")
        } -ThrottleLimit 30
    }
    $result.Count
}

注意：ConcurrentBag不保证元素顺序，但计数绝对准确，若无需固定顺序，此方案适用。

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