将写入过程添加到Get-Job/Wait-Job

Question

我正在使用以下代码以120秒的超时显示PowerShell作业的结果。我想通过合并 Write-Progress （基于完成的作业数）来增强此代码。我尝试使用此示例 ，当我尝试合并该代码时，Progress Bar在之后简要显示所有作业都已完成。

    $Jobs = @()
    $ForceStoppedIds = @{}
    
    $Jobs += Get-Job
    $Jobs | Wait-Job -Timeout 120 | Out-Null
    $Jobs | ?{$_.State -eq 'Running'} | Stop-Job -PassThru | %{$ForceStoppedIds[$_.Id] = $true}
    
    foreach ($Job in $Jobs) {
    
        $Name = $Job.Name
        $Output = (Get-Job -Name $Name | Receive-Job)
    
        if ($ForceStoppedIds.Contains($Job.Id)) {
    
            Write-Output "$($Name) - Device unable to process request within 2 minutes"
    
        } else {
    
            Write-Output $Output
    
        }
    
    }

Answer 1

Wait -Job -TimeOut 120 将阻止线程，直到指定的超时或所有作业完成，因此无法显示进度并同时等待它们。

我可以想到两种替代方案，第一个是创建一个 代理命令 /proxy功能围绕此cmdlet扩展其功能。

这些博客演示了如何做到：

• https://devblogs.microsoft.com/powershell/powershell/extering-anderding-anderding-andor-modifing-commands-with-proxies/
  

您还可以从

---

另一种选择是定义自己的功能，该功能执行类似的工作，例如 wait-job ，但是，您可以添加一个基于2个条件运行的循环，而不是阻止线程

• ：低于或等于我们作为参数传递给函数的超时（我们可以使用 diagnostics.stopwatch 为此）。
• 而且，工作仍然是运行（ $ obs

注意，下面的功能在大多数情况下应起作用，但是纯粹仅用于演示目的，不应依靠。

首先，我们定义一个可以用于显示进度的新功能，并根据超时等待我们的作业：

using namespace System.Collections.Generic
using namespace System.Diagnostics
using namespace System.Threading
using namespace System.Management.Automation

function Wait-JobWithProgress {
    [cmdletbinding()]
    param(
        [parameter(Mandatory, ValueFromPipeline)]
        [object[]] $InputObject,

        [parameter()]
        [ValidateRange(1, [double]::MaxValue)]
        [double] $TimeOut # In seconds!
    )

    begin {
        $jobs = [List[object]]::new()

        if ($withTimeOut = $PSBoundParameters.ContainsKey('TimeOut')) {
            $span = [timespan]::FromSeconds($TimeOut)
        }
    }

    process {
        $jobs.AddRange($InputObject)
    }

    end {
        $timer = [Stopwatch]::StartNew()
        $total = $jobs.Count
        $completed = 0.1

        while ($jobs.Count) {
            if ($withTimeOut -and $timer.Elapsed -gt $span) {
                break
            }

            $remaining = $total - $completed
            $average = $timer.Elapsed.TotalSeconds / $completed
            $estimate = [math]::Round($remaining * $average)
            $status = 'Completed Jobs: {0:0} of {1}' -f $completed, $total
            $progress = @{
                Activity         = 'Waiting for Jobs'
                PercentComplete  = $completed / $total * 100
                Status           = $status
                SecondsRemaining = $estimate
            }
            Write-Progress @progress

            $id = [WaitHandle]::WaitAny($jobs.Finished, 200)
            if ($id -eq [WaitHandle]::WaitTimeout) {
                continue
            }

            # output this job
            $jobs[$id]
            # remove this job
            $jobs.RemoveAt($id)
            $completed++
        }

        # Stop the jobs not yet Completed and remove them
        $jobs | Stop-Job -PassThru | ForEach-Object {
            Remove-Job -Job $_
            'Job [#{0} - {1}] did not complete on time and was removed.' -f $_.Id, $_.Name
        } | Write-Warning
        Write-Progress @progress -Completed
    }
}

为了测试它，我们可以使用随机计时器创建一些作业：

0..10 | ForEach-Object {
    Start-Job {
        Start-Sleep (Get-Random -Minimum 5 -Maximum 15)
        [pscustomobject]@{
            Job    = $using:_
            Result = 'Hello from [Job #{0:D2}]' -f $using:_
        }
    }
} | Wait-JobWithProgress -TimeOut 10 |
Receive-Job -AutoRemoveJob -Wait | Format-Table -AutoSize