PowerShell如何简单实现代码并行运行？数组并行处理求助

你的代码存在的核心问题 #

• 串行执行而非并行：在for循环中，每次创建Job后立刻调用Receive-Job -Wait，这会强制等待当前Job完成才进入下一次循环，完全失去了并行的意义。
• 数组分割逻辑错误：当前的区间计算会导致端口范围重叠（比如第二次循环的起始是2，而第一次循环的结束是6552，区间完全重叠），并且会漏掉65530~65535这最后5个端口，你的$last数组也没有被正确使用。
• 无实际处理逻辑：ForEach-Object -Parallel里仅返回$_，没有体现你要处理的业务逻辑，但即使有逻辑，当前的串行执行也无法提升速度。

修正后的并行实现代码 #

先修正分割逻辑，再实现真正的并行：

class CommonServicePorts {
    [int]$numberOfPorts = 65535;
    [int]$divisor = 10;
    [int]$roundedDown;
    [int[]] $last = @();

    [void] GetAllPorts() {
        $this.roundedDown = [Math]::Floor($this.numberOfPorts / $this.divisor);
        $jobs = @()

        # 启动所有并行Job
        for ($i = 0; $i -lt $this.divisor; $i++) {
            $startPort = $i * $this.roundedDown + 1
            $endPort = ($i + 1) * $this.roundedDown
            # 处理最后一批，补上剩余的端口
            if ($i -eq $this.divisor - 1) {
                $endPort = $this.numberOfPorts
            }
            # 启动Job，这里替换成你的实际处理逻辑
            $jobs += $startPort..$endPort | ForEach-Object -Parallel {
                # 示例：模拟处理，返回端口和处理标记
                [PSCustomObject]@{
                    Port = $_
                    Status = "Processed"
                }
            } -AsJob
        }

        # 统一等待所有Job完成并接收结果
        $results = $jobs | Receive-Job -Wait -AutoRemoveJob
        Write-Output $results
    }
}

$ports = [CommonServicePorts]::new();
$ports.GetAllPorts();

通用的PowerShell并行处理函数 #

如果需要一个可以随时复用的并行处理工具，可以封装成函数：

function Invoke-ParallelProcessing {
    param(
        [Parameter(Mandatory)]
        [array]$InputArray,
        [Parameter(Mandatory)]
        [scriptblock]$ProcessScript,
        [int]$BatchCount = 5
    )

    $batchSize = [Math]::Ceiling($InputArray.Count / $BatchCount)
    $jobs = @()

    # 分割数组并启动Job
    for ($i = 0; $i -lt $BatchCount; $i++) {
        $startIdx = $i * $batchSize
        $endIdx = [Math]::Min(($i + 1) * $batchSize - 1, $InputArray.Count - 1)
        if ($startIdx -gt $endIdx) { break }
        
        $batch = $InputArray[$startIdx..$endIdx]
        $jobs += $batch | ForEach-Object -Parallel $using:ProcessScript -AsJob
    }

    # 接收所有结果
    $results = $jobs | Receive-Job -Wait -AutoRemoveJob
    return $results
}

# 使用示例：处理端口数组
$allPorts = 1..65535
$processingResult = Invoke-ParallelProcessing -InputArray $allPorts -ProcessScript {
    # 这里写你的实际处理逻辑，比如扫描端口、验证服务等
    [PSCustomObject]@{
        Port = $_
        IsOpen = Test-NetConnection -ComputerName localhost -Port $_ -InformationLevel Quiet
    }
} -BatchCount 10

$processingResult | Out-GridView

关键注意事项 #

• 避免过度并行：BatchCount不要设置过大，否则会消耗过多系统资源，反而降低效率。根据你的CPU核心数和业务逻辑调整，一般4-10合适。
• using:关键字：在ForEach-Object -Parallel中引用外部变量时，必须使用$using:变量名，否则无法访问脚本块外的变量。
• Job资源清理：使用-AutoRemoveJob可以在接收结果后自动删除Job，避免残留资源。

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