PowerShell 多线程测试IP端口

阿牛

　　$queue = [System.Collections.Queue]::Synchronized( (New-Object System.Collections.Queue) )
　　$lines=gc C:\temp\thebigproxylist-17-12-20.txt
　　foreach($line in $lines){
　　$queue.enqueue($line)
　　}
　　write-host $queue.count
　　$Throttle = 5 #threads
　　#脚本块，对指定的IP测试端口，结果保存在一个对象里面
　　$ScriptBlock = {
　　Param (
　　[string]$value
　　)
　　$ip=$value.Split(":")[0]
　　$port=$value.Split(":")[1]
　　$a=test-netconnection -ComputerName $ip -Port $port
　　$RunResult = New-Object PSObject -Property @{
　　ComputerName=$ip
　　Port=$port
　　TCP=$a.TCPTestSucceeded
　　}
　　Return $RunResult
　　}
　　#创建一个资源池，指定多少个runspace可以同时执行
　　$RunspacePool = [RunspaceFactory]::CreateRunspacePool(1, $Throttle)
　　$RunspacePool.Open()
　　$Jobs = @()
　　for($i=1;$i -lt 20;$i++){
　　$currentvalue=$queue.Dequeue()
　　Write-Host $currentvalue
　　$Job = [powershell]::Create().AddScript($ScriptBlock).addargument($currentvalue)
　　$Job.RunspacePool = $RunspacePool
　　$Jobs += New-Object PSObject -Property @{
　　Server = $currentvalue
　　Pipe = $Job
　　Result = $Job.BeginInvoke()
　　}
　　}
　　#循环输出等待的信息.... 直到所有的job都完成
　　Write-Host "Waiting.." -NoNewline
　　Do {
　　Write-Host "." -NoNewline
　　Start-Sleep -Seconds 1
　　} While ( $Jobs.Result.IsCompleted -contains $false)
　　Write-Host "All jobs completed!"
　　#输出结果
　　$Results = @()
　　ForEach ($Job in $Jobs)
　　{   $Results += $Job.Pipe.EndInvoke($Job.Result)
　　}
　　$Results