如何无需等待整批完成，正确处理PowerShell作业执行句柄批处理？

我明白你想要的是无需等待所有作业完成，就能对每个完成的PowerShell作业实时进行处理，同时还能在出现失败作业时及时终止整批任务对吧？下面是优化后的实现，完美满足这个需求：

Function Process-JobsRealtime {
    [CmdletBinding()]
    param(
        [Parameter(ValueFromPipeline)]
        [System.Management.Automation.Job[]]$Job
    )
    begin {
        $jobs = @()
        $abortTriggered = $false
    }
    process {
        $jobs += $Job
    }
    end {
        # 持续监控作业状态，直到所有作业处理完毕或触发终止
        while (($jobs | Where-Object { $_.State -in 'Running', 'NotStarted' }).Count -gt 0 -and -not $abortTriggered) {
            # 筛选已完成（成功/失败）但未被处理过的作业
            $completedJobs = $jobs | Where-Object { $_.State -in 'Completed', 'Failed' -and -not $_.PSObject.Properties['Processed'] }
            
            foreach ($job in $completedJobs) {
                # 标记作业为已处理，避免重复执行逻辑
                $job | Add-Member -MemberType NoteProperty -Name 'Processed' -Value $true -Force
                
                if ($job.State -eq 'Failed') {
                    Write-Warning "作业 [$($job.Name)] 执行失败，将终止所有运行中的作业"
                    # 终止所有仍在运行的作业
                    $jobs | Where-Object { $_.State -eq 'Running' } | Stop-Job
                    $abortTriggered = $true
                    # 捕获失败作业的输出/错误信息
                    $jobError = $job | Receive-Job -ErrorAction SilentlyContinue
                    Write-Error "失败作业详情：$jobError"
                    continue
                }
                
                # 这里替换成你自己的成功作业处理逻辑
                Write-Host "作业 [$($job.Name)] 已成功完成，开始处理结果..."
                $jobResults = $job | Receive-Job
                # 示例：输出作业结果
                Write-Output "作业结果：$jobResults"
            }
            
            # 短时间休眠，避免过度占用CPU
            Start-Sleep -Milliseconds 300
        }
        
        # 清理所有作业资源，避免残留
        $jobs | Remove-Job -Force
        Write-Host "所有作业已清理完成"
    }
}

核心特性说明 #

• 实时处理：每次循环都会检查并处理已完成的作业，不用等到整批作业全部结束
• 避免重复处理：通过给作业添加Processed标记属性，确保每个作业只被处理一次
• 失败快速响应：一旦检测到失败作业，立刻终止所有运行中的任务，避免无效执行
• 资源自动清理：函数结束时强制移除所有作业，防止PowerShell中残留僵尸作业

使用示例 #

# 创建几个测试用的作业
$job1 = Start-Job -ScriptBlock { Start-Sleep 2; return "用户数据同步完成" }
$job2 = Start-Job -ScriptBlock { Start-Sleep 5; throw "数据库连接失败" }
$job3 = Start-Job -ScriptBlock { Start-Sleep 3; return "日志归档完成" }

# 实时处理这批作业
$job1, $job2, $job3 | Process-JobsRealtime

运行后你会看到：作业1先完成并被处理，接着是作业3，最后作业2失败触发终止逻辑，整个过程不需要等待所有作业跑完。

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