PoshCode Archive  Hex Artifact Content

Artifact d10b3a7cf291ef2e9da1e0b622d3e90b945b1f8da1393ee22fd0fc50e6d4b258:

  • File Split-Job-V.ps1 — part of check-in [e66aef07e1] at 2018-06-10 13:13:19 on branch trunk — The Split-Job function provides easy multithreading at the command line or in a script. It was created from a system administrator’s point of view and is compatible with PS v1. Supports importing functions, variables and snapins. For history and background please visit http://www.jansveld.net/powershell. (user: Arnoud Jansveld size: 12606)

0000: 23 20 65 6e 63 6f 64 69 6e 67 3a 20 61 73 63 69  # encoding: asci
0010: 69 0d 0a 23 20 61 70 69 3a 20 70 6f 77 65 72 73  i..# api: powers
0020: 68 65 6c 6c 0d 0a 23 20 74 69 74 6c 65 3a 20 53  hell..# title: S
0030: 70 6c 69 74 2d 4a 6f 62 20 56 0d 0a 23 20 64 65  plit-Job V..# de
0040: 73 63 72 69 70 74 69 6f 6e 3a 20 54 68 65 20 53  scription: The S
0050: 70 6c 69 74 2d 4a 6f 62 20 66 75 6e 63 74 69 6f  plit-Job functio
0060: 6e 20 70 72 6f 76 69 64 65 73 20 65 61 73 79 20  n provides easy 
0070: 6d 75 6c 74 69 74 68 72 65 61 64 69 6e 67 20 61  multithreading a
0080: 74 20 74 68 65 20 63 6f 6d 6d 61 6e 64 20 6c 69  t the command li
0090: 6e 65 20 6f 72 20 69 6e 20 61 20 73 63 72 69 70  ne or in a scrip
00a0: 74 2e 20 49 74 20 77 61 73 20 63 72 65 61 74 65  t. It was create
00b0: 64 20 66 72 6f 6d 20 61 20 73 79 73 74 65 6d 20  d from a system 
00c0: 61 64 6d 69 6e 69 73 74 72 61 74 6f 72 e2 80 99  administrator...
00d0: 73 20 70 6f 69 6e 74 20 6f 66 20 76 69 65 77 20  s point of view 
00e0: 61 6e 64 20 69 73 20 63 6f 6d 70 61 74 69 62 6c  and is compatibl
00f0: 65 20 77 69 74 68 20 50 53 20 76 31 2e 20 53 75  e with PS v1. Su
0100: 70 70 6f 72 74 73 20 69 6d 70 6f 72 74 69 6e 67  pports importing
0110: 20 66 75 6e 63 74 69 6f 6e 73 2c 20 76 61 72 69   functions, vari
0120: 61 62 6c 65 73 20 61 6e 64 20 73 6e 61 70 69 6e  ables and snapin
0130: 73 2e 20 46 6f 72 20 68 69 73 74 6f 72 79 20 61  s. For history a
0140: 6e 64 20 62 61 63 6b 67 72 6f 75 6e 64 20 70 6c  nd background pl
0150: 65 61 73 65 20 76 69 73 69 74 20 68 74 74 70 3a  ease visit http:
0160: 2f 2f 77 77 77 2e 6a 61 6e 73 76 65 6c 64 2e 6e  //www.jansveld.n
0170: 65 74 2f 70 6f 77 65 72 73 68 65 6c 6c 2e 0d 0a  et/powershell...
0180: 23 20 76 65 72 73 69 6f 6e 3a 20 31 2e 32 0d 0a  # version: 1.2..
0190: 23 20 74 79 70 65 3a 20 66 75 6e 63 74 69 6f 6e  # type: function
01a0: 0d 0a 23 20 61 75 74 68 6f 72 3a 20 41 72 6e 6f  ..# author: Arno
01b0: 75 64 20 4a 61 6e 73 76 65 6c 64 0d 0a 23 20 6c  ud Jansveld..# l
01c0: 69 63 65 6e 73 65 3a 20 43 43 30 0d 0a 23 20 66  icense: CC0..# f
01d0: 75 6e 63 74 69 6f 6e 3a 20 54 65 73 74 2d 57 65  unction: Test-We
01e0: 62 53 65 72 76 65 72 0d 0a 23 20 78 2d 70 6f 73  bServer..# x-pos
01f0: 68 63 6f 64 65 2d 69 64 3a 20 32 36 32 31 0d 0a  hcode-id: 2621..
0200: 23 20 78 2d 64 65 72 69 76 65 64 2d 66 72 6f 6d  # x-derived-from
0210: 2d 69 64 3a 20 33 36 37 39 0d 0a 23 20 78 2d 61  -id: 3679..# x-a
0220: 72 63 68 69 76 65 64 3a 20 32 30 31 35 2d 30 35  rchived: 2015-05
0230: 2d 30 36 54 31 38 3a 32 38 3a 32 39 0d 0a 23 20  -06T18:28:29..# 
0240: 78 2d 70 75 62 6c 69 73 68 65 64 3a 20 32 30 31  x-published: 201
0250: 31 2d 30 34 2d 32 31 54 31 34 3a 34 33 3a 30 30  1-04-21T14:43:00
0260: 0d 0a 23 0d 0a 23 20 54 68 69 73 20 69 73 20 56  ..#..# This is V
0270: 65 72 73 69 6f 6e 20 31 2e 32 20 61 6e 64 20 6f  ersion 1.2 and o
0280: 6e 6c 79 20 77 6f 72 6b 20 69 6e 20 50 6f 77 65  nly work in Powe
0290: 72 53 68 65 6c 6c 20 56 20 32 2e 20 20 49 74 20  rShell V 2.  It 
02a0: 73 75 70 70 6f 72 74 73 20 70 6f 77 65 72 73 68  supports powersh
02b0: 65 6c 6c 5f 69 73 65 20 61 6e 64 20 77 69 6c 6c  ell_ise and will
02c0: 20 63 61 6e 63 65 6c 20 70 69 70 65 6c 69 6e 65   cancel pipeline
02d0: 73 20 69 66 20 65 73 63 61 70 65 20 69 73 20 70  s if escape is p
02e0: 72 65 73 73 65 64 2e 20 20 49 74 20 61 6c 73 6f  ressed.  It also
02f0: 20 69 6e 63 6c 75 64 65 73 20 76 61 72 69 6f 75   includes variou
0300: 73 20 6f 74 68 65 72 20 6d 69 6e 6f 72 20 69 6d  s other minor im
0310: 70 72 6f 76 65 6d 65 6e 74 73 2e 0d 0a 23 0d 0a  provements...#..
0320: 23 72 65 71 75 69 72 65 73 20 2d 76 65 72 73 69  #requires -versi
0330: 6f 6e 20 32 2e 30 0d 0a 3c 23 0d 0a 23 23 23 23  on 2.0..<#..####
0340: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
0350: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
0360: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
0370: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
0380: 23 23 23 23 23 23 23 23 23 23 23 23 0d 0a 23 23  ############..##
0390: 20 52 75 6e 20 63 6f 6d 6d 61 6e 64 73 20 69 6e   Run commands in
03a0: 20 6d 75 6c 74 69 70 6c 65 20 63 6f 6e 63 75 72   multiple concur
03b0: 72 65 6e 74 20 70 69 70 65 6c 69 6e 65 73 0d 0a  rent pipelines..
03c0: 23 23 20 20 20 62 79 20 41 72 6e 6f 75 64 20 4a  ##   by Arnoud J
03d0: 61 6e 73 76 65 6c 64 20 2d 20 77 77 77 2e 6a 61  ansveld - www.ja
03e0: 6e 73 76 65 6c 64 2e 6e 65 74 2f 70 6f 77 65 72  nsveld.net/power
03f0: 73 68 65 6c 6c 0d 0a 23 23 0d 0a 23 23 20 42 61  shell..##..## Ba
0400: 73 69 63 20 22 64 72 6f 70 20 69 6e 22 20 75 73  sic "drop in" us
0410: 61 67 65 20 65 78 61 6d 70 6c 65 73 3a 0d 0a 23  age examples:..#
0420: 23 20 20 20 2d 20 46 75 6e 63 74 69 6f 6e 73 20  #   - Functions 
0430: 74 68 61 74 20 61 63 63 65 70 74 20 70 69 70 65  that accept pipe
0440: 6c 69 6e 65 64 20 69 6e 70 75 74 3a 0d 0a 23 23  lined input:..##
0450: 20 20 20 20 20 20 20 57 69 74 68 6f 75 74 20 53         Without S
0460: 70 6c 69 74 2d 4a 6f 62 3a 0d 0a 23 23 20 20 20  plit-Job:..##   
0470: 20 20 20 20 20 20 20 47 65 74 2d 43 6f 6e 74 65         Get-Conte
0480: 6e 74 20 68 6f 73 74 73 2e 74 78 74 20 7c 20 4d  nt hosts.txt | M
0490: 79 46 75 6e 63 74 69 6f 6e 20 7c 20 45 78 70 6f  yFunction | Expo
04a0: 72 74 2d 43 73 76 20 72 65 73 75 6c 74 73 2e 63  rt-Csv results.c
04b0: 73 76 0d 0a 23 23 20 20 20 20 20 20 20 57 69 74  sv..##       Wit
04c0: 68 20 53 70 6c 69 74 2d 4a 6f 62 3a 0d 0a 23 23  h Split-Job:..##
04d0: 20 20 20 20 20 20 20 20 20 20 47 65 74 2d 43 6f            Get-Co
04e0: 6e 74 65 6e 74 20 68 6f 73 74 73 2e 74 78 74 20  ntent hosts.txt 
04f0: 7c 20 53 70 6c 69 74 2d 4a 6f 62 20 7b 4d 79 46  | Split-Job {MyF
0500: 75 6e 63 74 69 6f 6e 7d 20 7c 20 45 78 70 6f 72  unction} | Expor
0510: 74 2d 43 73 76 20 72 65 73 75 6c 74 73 2e 63 73  t-Csv results.cs
0520: 76 0d 0a 23 23 20 20 20 2d 20 46 75 6e 63 74 69  v..##   - Functi
0530: 6f 6e 73 20 74 68 61 74 20 64 6f 20 6e 6f 74 20  ons that do not 
0540: 61 63 63 65 70 74 20 70 69 70 65 6c 69 6e 65 64  accept pipelined
0550: 20 69 6e 70 75 74 20 28 75 73 65 20 66 6f 72 65   input (use fore
0560: 61 63 68 29 3a 0d 0a 23 23 20 20 20 20 20 20 20  ach):..##       
0570: 57 69 74 68 6f 75 74 20 53 70 6c 69 74 2d 4a 6f  Without Split-Jo
0580: 62 3a 0d 0a 23 23 20 20 20 20 20 20 20 20 20 20  b:..##          
0590: 47 65 74 2d 43 6f 6e 74 65 6e 74 20 68 6f 73 74  Get-Content host
05a0: 73 2e 74 78 74 20 7c 25 20 7b 20 2e 5c 4d 79 53  s.txt |% { .\MyS
05b0: 63 72 69 70 74 2e 70 73 31 20 2d 43 6f 6d 70 75  cript.ps1 -Compu
05c0: 74 65 72 4e 61 6d 65 20 24 5f 20 7d 20 7c 20 45  terName $_ } | E
05d0: 78 70 6f 72 74 2d 43 73 76 20 72 65 73 75 6c 74  xport-Csv result
05e0: 73 2e 63 73 76 0d 0a 23 23 20 20 20 20 20 20 20  s.csv..##       
05f0: 57 69 74 68 20 53 70 6c 69 74 2d 4a 6f 62 3a 0d  With Split-Job:.
0600: 0a 23 23 20 20 20 20 20 20 20 20 20 20 47 65 74  .##          Get
0610: 2d 43 6f 6e 74 65 6e 74 20 68 6f 73 74 73 2e 74  -Content hosts.t
0620: 78 74 20 7c 20 53 70 6c 69 74 2d 4a 6f 62 20 7b  xt | Split-Job {
0630: 25 7b 20 2e 5c 4d 79 53 63 72 69 70 74 2e 70 73  %{ .\MyScript.ps
0640: 31 20 2d 43 6f 6d 70 75 74 65 72 4e 61 6d 65 20  1 -ComputerName 
0650: 24 5f 20 7d 7d 20 7c 20 45 78 70 6f 72 74 2d 43  $_ }} | Export-C
0660: 73 76 20 72 65 73 75 6c 74 73 2e 63 73 76 0d 0a  sv results.csv..
0670: 23 23 0d 0a 23 23 20 45 78 61 6d 70 6c 65 20 77  ##..## Example w
0680: 69 74 68 20 61 6e 20 69 6d 70 6f 72 74 65 64 20  ith an imported 
0690: 66 75 6e 63 74 69 6f 6e 3a 0d 0a 23 23 20 20 20  function:..##   
06a0: 20 20 20 20 66 75 6e 63 74 69 6f 6e 20 54 65 73      function Tes
06b0: 74 2d 57 65 62 53 65 72 76 65 72 20 28 24 43 6f  t-WebServer ($Co
06c0: 6d 70 75 74 65 72 4e 61 6d 65 29 20 7b 0d 0a 23  mputerName) {..#
06d0: 23 20 20 20 20 20 20 20 20 20 20 20 24 57 65 62  #           $Web
06e0: 52 65 71 75 65 73 74 20 3d 20 5b 53 79 73 74 65  Request = [Syste
06f0: 6d 2e 4e 65 74 2e 57 65 62 52 65 71 75 65 73 74  m.Net.WebRequest
0700: 5d 3a 3a 43 72 65 61 74 65 28 22 68 74 74 70 3a  ]::Create("http:
0710: 2f 2f 24 43 6f 6d 70 75 74 65 72 4e 61 6d 65 22  //$ComputerName"
0720: 29 0d 0a 23 23 20 20 20 20 20 20 20 20 20 20 20  )..##           
0730: 24 57 65 62 52 65 71 75 65 73 74 2e 47 65 74 52  $WebRequest.GetR
0740: 65 73 70 6f 6e 73 65 28 29 0d 0a 23 23 20 20 20  esponse()..##   
0750: 20 20 20 20 7d 0d 0a 23 23 20 20 20 20 20 20 20      }..##       
0760: 47 65 74 2d 43 6f 6e 74 65 6e 74 20 68 6f 73 74  Get-Content host
0770: 73 2e 74 78 74 20 7c 20 53 70 6c 69 74 2d 4a 6f  s.txt | Split-Jo
0780: 62 20 7b 25 7b 54 65 73 74 2d 57 65 62 53 65 72  b {%{Test-WebSer
0790: 76 65 72 20 24 5f 20 7d 7d 20 2d 46 75 6e 63 74  ver $_ }} -Funct
07a0: 69 6f 6e 20 54 65 73 74 2d 57 65 62 53 65 72 76  ion Test-WebServ
07b0: 65 72 20 7c 20 45 78 70 6f 72 74 2d 43 73 76 20  er | Export-Csv 
07c0: 72 65 73 75 6c 74 73 2e 63 73 76 0d 0a 23 23 0d  results.csv..##.
07d0: 0a 23 23 20 45 78 61 6d 70 6c 65 20 77 69 74 68  .## Example with
07e0: 20 69 6d 70 6f 72 74 69 6e 67 20 61 20 6d 6f 64   importing a mod
07f0: 75 6c 65 0d 0a 23 23 20 20 20 20 20 20 20 47 65  ule..##       Ge
0800: 74 2d 43 6f 6e 74 65 6e 74 20 43 6c 75 73 74 65  t-Content Cluste
0810: 72 73 2e 74 78 74 20 7c 20 53 70 6c 69 74 2d 4a  rs.txt | Split-J
0820: 6f 62 20 7b 20 25 20 7b 20 47 65 74 2d 43 6c 75  ob { % { Get-Clu
0830: 73 74 65 72 20 2d 4e 61 6d 65 20 24 5f 20 7d 20  ster -Name $_ } 
0840: 7d 20 2d 49 6e 69 74 69 61 6c 69 7a 65 53 63 72  } -InitializeScr
0850: 69 70 74 20 7b 20 49 6d 70 6f 72 74 2d 4d 6f 64  ipt { Import-Mod
0860: 75 6c 65 20 46 61 69 6c 6f 76 65 72 43 6c 75 73  ule FailoverClus
0870: 74 65 72 73 20 7d 0d 0a 23 23 09 0d 0a 23 23 0d  ters }..##...##.
0880: 0a 23 23 20 56 65 72 73 69 6f 6e 20 48 69 73 74  .## Version Hist
0890: 6f 72 79 0d 0a 23 23 20 31 2e 32 20 20 20 20 43  ory..## 1.2    C
08a0: 68 61 6e 67 65 73 20 62 79 20 53 74 65 70 68 65  hanges by Stephe
08b0: 6e 20 4d 69 6c 6c 73 20 2d 20 73 74 65 70 68 65  n Mills - stephe
08c0: 6e 6d 69 6c 6c 73 20 61 74 20 68 6f 74 6d 61 69  nmills at hotmai
08d0: 6c 20 64 6f 74 20 63 6f 6d 0d 0a 23 23 20 20 20  l dot com..##   
08e0: 20 20 20 20 20 4f 6e 6c 79 20 77 6f 72 6b 73 20       Only works 
08f0: 77 69 74 68 20 50 6f 77 65 72 53 68 65 6c 6c 20  with PowerShell 
0900: 56 32 0d 0a 23 23 20 20 20 20 20 20 20 20 4d 6f  V2..##        Mo
0910: 64 69 66 69 65 64 20 65 72 72 6f 72 20 6f 75 74  dified error out
0920: 70 75 74 20 74 6f 20 75 73 65 20 45 72 72 6f 72  put to use Error
0930: 52 65 63 6f 72 64 20 70 61 72 61 6d 65 74 65 72  Record parameter
0940: 20 6f 66 20 57 72 69 74 65 2d 45 72 72 6f 72 20   of Write-Error 
0950: 2d 20 63 61 74 63 68 65 73 20 43 61 74 65 67 6f  - catches Catego
0960: 72 79 20 49 6e 66 6f 20 74 68 65 6e 2e 0d 0a 23  ry Info then...#
0970: 23 20 20 20 20 20 20 20 20 57 6f 72 6b 73 20 63  #        Works c
0980: 6f 72 72 65 63 74 6c 79 20 69 6e 20 70 6f 77 65  orrectly in powe
0990: 72 73 68 65 6c 6c 5f 69 73 65 2e 20 20 50 72 65  rshell_ise.  Pre
09a0: 76 69 6f 75 73 20 76 65 72 73 69 6f 6e 20 77 6f  vious version wo
09b0: 75 6c 64 20 6c 65 74 20 70 69 70 65 6c 69 6e 65  uld let pipeline
09c0: 73 20 63 6f 6e 74 69 6e 75 65 20 69 66 20 45 53  s continue if ES
09d0: 43 20 77 61 73 20 70 72 65 73 73 65 64 2e 20 20  C was pressed.  
09e0: 49 66 20 45 73 63 61 70 65 20 70 72 65 73 73 65  If Escape presse
09f0: 64 2c 20 74 68 65 6e 20 69 74 20 77 69 6c 6c 20  d, then it will 
0a00: 64 6f 20 61 6e 20 61 73 79 6e 63 20 63 61 6e 63  do an async canc
0a10: 65 6c 20 6f 66 20 74 68 65 20 70 69 70 65 6c 69  el of the pipeli
0a20: 6e 65 73 20 61 6e 64 20 65 78 69 74 2e 0d 0a 23  nes and exit...#
0a30: 23 20 20 20 20 20 20 20 20 41 64 64 20 73 65 63  #        Add sec
0a40: 6f 6e 64 73 20 72 65 6d 61 69 6e 69 6e 67 20 74  onds remaining t
0a50: 6f 20 70 72 6f 67 72 65 73 73 20 62 61 72 0d 0a  o progress bar..
0a60: 23 23 20 20 20 20 20 20 20 20 50 61 72 61 6d 65  ##        Parame
0a70: 74 65 72 73 20 41 64 64 65 64 20 61 6e 64 20 72  ters Added and r
0a80: 65 6c 61 74 65 64 20 66 75 6e 63 74 69 6f 6e 61  elated functiona
0a90: 6c 69 74 79 3a 0d 0a 23 23 20 20 20 20 20 20 20  lity:..##       
0aa0: 20 20 20 20 49 6e 69 74 69 61 6c 69 7a 65 53 63      InitializeSc
0ab0: 72 69 70 74 20 2d 20 61 6c 6c 6f 77 73 20 74 6f  ript - allows to
0ac0: 20 68 61 76 65 20 63 75 73 74 6f 6d 20 73 63 72   have custom scr
0ad0: 69 70 74 73 20 74 6f 20 69 6e 69 74 69 6c 69 7a  ipts to initiliz
0ae0: 65 20 28 20 49 6d 70 6f 72 74 2d 4d 6f 64 75 6c  e ( Import-Modul
0af0: 65 20 2e 2e 2e 29 2c 20 70 61 72 61 6d 65 74 65  e ...), paramete
0b00: 72 20 6d 69 67 68 74 20 62 65 20 72 65 6e 61 6d  r might be renam
0b10: 65 64 20 42 65 67 69 6e 20 69 6e 20 74 68 65 20  ed Begin in the 
0b20: 66 75 74 75 72 65 2e 0d 0a 23 23 20 20 20 20 20  future...##     
0b30: 20 20 20 20 20 20 4d 61 78 44 75 72 61 74 69 6f        MaxDuratio
0b40: 6e 20 2d 20 43 61 6e 63 65 6c 20 61 6c 6c 20 70  n - Cancel all p
0b50: 65 6e 64 69 6e 67 20 61 6e 64 20 69 6e 20 70 72  ending and in pr
0b60: 6f 63 65 73 73 20 69 74 65 6d 73 20 69 6e 20 71  ocess items in q
0b70: 75 65 75 65 20 69 66 20 74 68 65 20 6e 75 6d 62  ueue if the numb
0b80: 65 72 20 6f 66 20 73 65 63 6f 6e 64 73 20 69 73  er of seconds is
0b90: 20 72 65 61 63 68 65 64 20 62 65 66 6f 72 65 20   reached before 
0ba0: 61 6c 6c 20 69 6e 70 75 74 20 69 73 20 64 6f 6e  all input is don
0bb0: 65 2e 0d 0a 23 23 20 20 20 20 20 20 20 20 20 20  e...##          
0bc0: 20 50 72 6f 67 72 65 73 73 49 6e 66 6f 20 2d 20   ProgressInfo - 
0bd0: 41 6c 6c 6f 77 73 20 79 6f 75 20 74 6f 20 61 64  Allows you to ad
0be0: 64 20 61 64 64 69 74 69 6f 6e 61 6c 20 74 65 78  d additional tex
0bf0: 74 20 74 6f 20 70 72 6f 67 72 65 73 73 20 62 61  t to progress ba
0c00: 72 0d 0a 23 23 20 20 20 20 20 20 20 20 20 20 20  r..##           
0c10: 4e 6f 50 72 6f 67 72 65 73 73 20 2d 20 48 69 64  NoProgress - Hid
0c20: 65 20 50 72 6f 67 72 65 73 73 20 42 61 72 0d 0a  e Progress Bar..
0c30: 23 23 20 20 20 20 20 20 20 20 20 20 20 44 69 73  ##           Dis
0c40: 70 6c 61 79 49 6e 74 65 72 76 61 6c 20 2d 20 66  playInterval - f
0c50: 72 65 71 75 65 6e 63 79 20 74 6f 20 75 70 64 61  requency to upda
0c60: 74 65 20 50 72 6f 67 72 65 73 73 20 62 61 72 20  te Progress bar 
0c70: 69 6e 20 6d 69 6c 6c 69 73 65 63 6f 6e 64 73 0d  in milliseconds.
0c80: 0a 23 23 20 20 20 20 20 20 20 20 20 20 20 49 6e  .##           In
0c90: 70 75 74 4f 62 6a 65 63 74 20 2d 20 6e 6f 74 20  putObject - not 
0ca0: 79 65 74 20 75 73 65 64 2c 20 70 6c 61 6e 6e 65  yet used, planne
0cb0: 64 20 74 6f 20 62 65 20 75 73 65 64 20 69 6e 20  d to be used in 
0cc0: 66 75 74 75 72 65 20 74 6f 20 73 75 70 70 6f 72  future to suppor
0cd0: 74 20 73 74 61 72 74 20 70 72 6f 63 65 73 73 69  t start processi
0ce0: 6e 67 20 74 68 65 20 71 75 65 75 65 20 62 65 66  ng the queue bef
0cf0: 6f 72 65 20 70 69 70 65 6c 69 6e 65 20 69 73 6e  ore pipeline isn
0d00: 27 74 20 66 69 6e 69 73 68 65 64 20 79 65 74 0d  't finished yet.
0d10: 0a 23 23 20 20 20 20 20 20 20 20 41 64 64 65 64  .##        Added
0d20: 20 65 78 61 6d 70 6c 65 20 66 6f 72 20 69 6d 70   example for imp
0d30: 6f 72 74 69 6e 67 20 61 20 6d 6f 64 75 6c 65 2e  orting a module.
0d40: 0d 0a 23 23 20 31 2e 30 20 20 20 20 46 69 72 73  ..## 1.0    Firs
0d50: 74 20 76 65 72 73 69 6f 6e 20 70 6f 73 74 65 64  t version posted
0d60: 20 6f 6e 20 70 6f 73 68 63 6f 64 65 2e 6f 72 67   on poshcode.org
0d70: 0d 0a 23 23 20 20 20 20 20 20 20 20 41 64 64 69  ..##        Addi
0d80: 74 69 6f 6e 61 6c 20 72 75 6e 73 70 61 63 65 20  tional runspace 
0d90: 65 72 72 6f 72 20 63 68 65 63 6b 69 6e 67 20 61  error checking a
0da0: 6e 64 20 63 6c 65 61 6e 75 70 0d 0a 23 23 20 30  nd cleanup..## 0
0db0: 2e 39 33 20 20 20 49 6d 70 72 6f 76 65 20 65 72  .93   Improve er
0dc0: 72 6f 72 20 68 61 6e 64 6c 69 6e 67 3a 20 65 72  ror handling: er
0dd0: 72 6f 72 73 20 6f 72 69 67 69 6e 61 74 69 6e 67  rors originating
0de0: 20 69 6e 20 74 68 65 20 53 63 72 69 70 74 62 6c   in the Scriptbl
0df0: 6f 63 6b 20 6e 6f 77 0d 0a 23 23 20 20 20 20 20  ock now..##     
0e00: 20 20 20 68 61 76 65 20 6d 6f 72 65 20 6d 65 61     have more mea
0e10: 6e 69 6e 67 66 75 6c 20 6f 75 74 70 75 74 0d 0a  ningful output..
0e20: 23 23 20 20 20 20 20 20 20 20 53 68 6f 77 20 61  ##        Show a
0e30: 64 64 69 74 69 6f 6e 61 6c 20 69 6e 66 6f 20 69  dditional info i
0e40: 6e 20 74 68 65 20 70 72 6f 67 72 65 73 73 20 62  n the progress b
0e50: 61 72 20 28 74 68 61 6e 6b 73 20 53 74 65 70 68  ar (thanks Steph
0e60: 65 6e 20 4d 69 6c 6c 73 29 0d 0a 23 23 20 20 20  en Mills)..##   
0e70: 20 20 20 20 20 41 64 64 20 53 6e 61 70 49 6e 20       Add SnapIn 
0e80: 70 61 72 61 6d 65 74 65 72 3a 20 69 6d 70 6f 72  parameter: impor
0e90: 74 73 20 28 72 65 67 69 73 74 65 72 65 64 29 20  ts (registered) 
0ea0: 50 6f 77 65 72 53 68 65 6c 6c 20 73 6e 61 70 69  PowerShell snapi
0eb0: 6e 73 0d 0a 23 23 20 20 20 20 20 20 20 20 41 64  ns..##        Ad
0ec0: 64 20 46 75 6e 63 74 69 6f 6e 20 70 61 72 61 6d  d Function param
0ed0: 65 74 65 72 3a 20 69 6d 70 6f 72 74 73 20 66 75  eter: imports fu
0ee0: 6e 63 74 69 6f 6e 73 0d 0a 23 23 20 20 20 20 20  nctions..##     
0ef0: 20 20 20 41 64 64 20 53 70 6c 69 74 4a 6f 62 52     Add SplitJobR
0f00: 75 6e 53 70 61 63 65 20 76 61 72 69 61 62 6c 65  unSpace variable
0f10: 3b 20 61 6c 6c 6f 77 73 20 73 63 72 69 70 74 73  ; allows scripts
0f20: 20 74 6f 20 74 65 73 74 20 69 66 20 74 68 65 79   to test if they
0f30: 20 61 72 65 0d 0a 23 23 20 20 20 20 20 20 20 20   are..##        
0f40: 72 75 6e 6e 69 6e 67 20 69 6e 20 61 20 72 75 6e  running in a run
0f50: 73 70 61 63 65 0d 0a 23 23 20 30 2e 39 32 20 20  space..## 0.92  
0f60: 20 41 64 64 20 55 73 65 50 72 6f 66 69 6c 65 20   Add UseProfile 
0f70: 73 77 69 74 63 68 3a 20 69 6d 70 6f 72 74 73 20  switch: imports 
0f80: 74 68 65 20 50 53 20 70 72 6f 66 69 6c 65 0d 0a  the PS profile..
0f90: 23 23 20 20 20 20 20 20 20 20 41 64 64 20 56 61  ##        Add Va
0fa0: 72 69 61 62 6c 65 20 70 61 72 61 6d 65 74 65 72  riable parameter
0fb0: 3a 20 69 6d 70 6f 72 74 73 20 76 61 72 69 61 62  : imports variab
0fc0: 6c 65 73 0d 0a 23 23 20 20 20 20 20 20 20 20 41  les..##        A
0fd0: 64 64 20 41 6c 69 61 73 20 70 61 72 61 6d 65 74  dd Alias paramet
0fe0: 65 72 3a 20 69 6d 70 6f 72 74 73 20 61 6c 69 61  er: imports alia
0ff0: 73 65 73 0d 0a 23 23 20 20 20 20 20 20 20 20 52  ses..##        R
1000: 65 73 74 61 72 74 20 70 69 70 65 6c 69 6e 65 20  estart pipeline 
1010: 69 66 20 69 74 20 73 74 6f 70 73 20 64 75 65 20  if it stops due 
1020: 74 6f 20 61 6e 20 65 72 72 6f 72 0d 0a 23 23 20  to an error..## 
1030: 20 20 20 20 20 20 20 53 65 74 20 74 68 65 20 63         Set the c
1040: 75 72 72 65 6e 74 20 70 61 74 68 20 69 6e 20 65  urrent path in e
1050: 61 63 68 20 72 75 6e 73 70 61 63 65 20 74 6f 20  ach runspace to 
1060: 74 68 61 74 20 6f 66 20 74 68 65 20 63 61 6c 6c  that of the call
1070: 69 6e 67 20 70 72 6f 63 65 73 73 0d 0a 23 23 20  ing process..## 
1080: 30 2e 39 31 20 20 20 52 65 76 65 72 74 20 74 6f  0.91   Revert to
1090: 20 76 20 30 2e 38 20 69 6e 70 75 74 20 73 79 6e   v 0.8 input syn
10a0: 74 61 78 20 66 6f 72 20 74 68 65 20 73 63 72 69  tax for the scri
10b0: 70 74 20 62 6c 6f 63 6b 0d 0a 23 23 20 20 20 20  pt block..##    
10c0: 20 20 20 20 41 64 64 20 65 72 72 6f 72 20 68 61      Add error ha
10d0: 6e 64 6c 69 6e 67 20 66 6f 72 20 65 6d 70 74 79  ndling for empty
10e0: 20 69 6e 70 75 74 20 71 75 65 75 65 0d 0a 23 23   input queue..##
10f0: 20 30 2e 39 20 20 20 20 41 64 64 20 6c 6f 67 69   0.9    Add logi
1100: 63 20 74 6f 20 64 69 73 74 69 6e 67 75 69 73 68  c to distinguish
1110: 20 62 65 74 77 65 65 6e 20 73 63 72 69 70 74 62   between scriptb
1120: 6c 6f 63 6b 73 20 61 6e 64 20 63 6d 64 6c 65 74  locks and cmdlet
1130: 73 20 6f 72 20 73 63 72 69 70 74 73 3a 0d 0a 23  s or scripts:..#
1140: 23 20 20 20 20 20 20 20 20 69 66 20 61 20 53 63  #        if a Sc
1150: 72 69 70 74 42 6c 6f 63 6b 20 69 73 20 73 70 65  riptBlock is spe
1160: 63 69 66 69 65 64 2c 20 61 20 66 6f 72 65 61 63  cified, a foreac
1170: 68 20 7b 7d 20 77 72 61 70 70 65 72 20 69 73 20  h {} wrapper is 
1180: 61 64 64 65 64 0d 0a 23 23 20 30 2e 38 20 20 20  added..## 0.8   
1190: 20 41 64 64 73 20 61 20 70 72 6f 67 72 65 73 73   Adds a progress
11a0: 20 62 61 72 0d 0a 23 23 20 30 2e 37 20 20 20 20   bar..## 0.7    
11b0: 53 74 6f 70 20 61 64 64 69 6e 67 20 72 75 6e 73  Stop adding runs
11c0: 70 61 63 65 73 20 69 66 20 74 68 65 20 71 75 65  paces if the que
11d0: 75 65 20 69 73 20 61 6c 72 65 61 64 79 20 65 6d  ue is already em
11e0: 70 74 79 0d 0a 23 23 20 30 2e 36 20 20 20 20 46  pty..## 0.6    F
11f0: 69 72 73 74 20 76 65 72 73 69 6f 6e 2e 20 49 6e  irst version. In
1200: 73 70 69 72 65 64 20 62 79 20 47 61 75 72 68 6f  spired by Gaurho
1210: 74 68 27 73 20 4e 65 77 2d 54 61 73 6b 50 6f 6f  th's New-TaskPoo
1220: 6c 20 73 63 72 69 70 74 0d 0a 23 23 23 23 23 23  l script..######
1230: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
1240: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
1250: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
1260: 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23 23  ################
1270: 23 23 23 23 23 23 23 23 23 23 0d 0a 23 3e 0d 0a  ##########..#>..
1280: 0d 0a 66 75 6e 63 74 69 6f 6e 20 53 70 6c 69 74  ..function Split
1290: 2d 4a 6f 62 0d 0a 7b 0d 0a 09 70 61 72 61 6d 20  -Job..{...param 
12a0: 28 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65 72 28  (....[Parameter(
12b0: 50 6f 73 69 74 69 6f 6e 3d 30 2c 20 4d 61 6e 64  Position=0, Mand
12c0: 61 74 6f 72 79 3d 24 74 72 75 65 29 5d 24 53 63  atory=$true)]$Sc
12d0: 72 69 70 74 62 6c 6f 63 6b 2c 0d 0a 09 09 5b 50  riptblock,....[P
12e0: 61 72 61 6d 65 74 65 72 28 29 5d 5b 69 6e 74 5d  arameter()][int]
12f0: 24 4d 61 78 50 69 70 65 6c 69 6e 65 73 3d 31 30  $MaxPipelines=10
1300: 2c 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65 72 28  ,....[Parameter(
1310: 29 5d 5b 73 77 69 74 63 68 5d 24 55 73 65 50 72  )][switch]$UsePr
1320: 6f 66 69 6c 65 2c 0d 0a 09 09 5b 50 61 72 61 6d  ofile,....[Param
1330: 65 74 65 72 28 29 5d 5b 73 74 72 69 6e 67 5b 5d  eter()][string[]
1340: 5d 24 56 61 72 69 61 62 6c 65 2c 0d 0a 09 09 5b  ]$Variable,....[
1350: 50 61 72 61 6d 65 74 65 72 28 29 5d 5b 73 74 72  Parameter()][str
1360: 69 6e 67 5b 5d 5d 24 46 75 6e 63 74 69 6f 6e 20  ing[]]$Function 
1370: 3d 20 40 28 29 2c 0d 0a 09 09 5b 50 61 72 61 6d  = @(),....[Param
1380: 65 74 65 72 28 29 5d 5b 73 74 72 69 6e 67 5b 5d  eter()][string[]
1390: 5d 24 41 6c 69 61 73 20 3d 20 40 28 29 2c 0d 0a  ]$Alias = @(),..
13a0: 09 09 5b 50 61 72 61 6d 65 74 65 72 28 29 5d 5b  ..[Parameter()][
13b0: 73 74 72 69 6e 67 5b 5d 5d 24 53 6e 61 70 49 6e  string[]]$SnapIn
13c0: 2c 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65 72 28  ,....[Parameter(
13d0: 29 5d 5b 66 6c 6f 61 74 5d 24 4d 61 78 44 75 72  )][float]$MaxDur
13e0: 61 74 69 6f 6e 20 3d 20 24 28 20 5b 49 6e 74 5d  ation = $( [Int]
13f0: 3a 3a 4d 61 78 56 61 6c 75 65 20 29 2c 0d 0a 09  ::MaxValue ),...
1400: 09 5b 50 61 72 61 6d 65 74 65 72 28 29 5d 5b 73  .[Parameter()][s
1410: 74 72 69 6e 67 5d 24 50 72 6f 67 72 65 73 73 49  tring]$ProgressI
1420: 6e 66 6f 20 3d 27 27 2c 0d 0a 09 09 5b 50 61 72  nfo ='',....[Par
1430: 61 6d 65 74 65 72 28 29 5d 5b 69 6e 74 5d 24 50  ameter()][int]$P
1440: 72 6f 67 72 65 73 73 49 44 20 3d 20 30 2c 0d 0a  rogressID = 0,..
1450: 09 09 5b 50 61 72 61 6d 65 74 65 72 28 29 5d 5b  ..[Parameter()][
1460: 73 77 69 74 63 68 5d 24 4e 6f 50 72 6f 67 72 65  switch]$NoProgre
1470: 73 73 2c 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65  ss,....[Paramete
1480: 72 28 29 5d 5b 69 6e 74 5d 24 44 69 73 70 6c 61  r()][int]$Displa
1490: 79 49 6e 74 65 72 76 61 6c 20 3d 20 33 30 30 2c  yInterval = 300,
14a0: 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65 72 28 29  ....[Parameter()
14b0: 5d 5b 73 63 72 69 70 74 62 6c 6f 63 6b 5d 24 49  ][scriptblock]$I
14c0: 6e 69 74 69 61 6c 69 7a 65 53 63 72 69 70 74 2c  nitializeScript,
14d0: 0d 0a 09 09 5b 50 61 72 61 6d 65 74 65 72 28 56  ....[Parameter(V
14e0: 61 6c 75 65 46 72 6f 6d 50 69 70 65 6c 69 6e 65  alueFromPipeline
14f0: 3d 24 74 72 75 65 29 5d 5b 6f 62 6a 65 63 74 5b  =$true)][object[
1500: 5d 5d 24 49 6e 70 75 74 4f 62 6a 65 63 74 0d 0a  ]]$InputObject..
1510: 09 29 0d 0a 0d 0a 09 62 65 67 69 6e 0d 0a 09 7b  .).....begin...{
1520: 0d 0a 09 09 24 53 74 61 72 74 54 69 6d 65 20 3d  ....$StartTime =
1530: 20 47 65 74 2d 44 61 74 65 0d 0a 09 09 23 24 44   Get-Date....#$D
1540: 69 73 70 6c 61 79 54 69 6d 65 20 3d 20 24 53 74  isplayTime = $St
1550: 61 72 74 54 69 6d 65 2e 41 64 64 4d 69 6c 6c 69  artTime.AddMilli
1560: 73 65 63 6f 6e 64 73 28 20 2d 20 24 44 69 73 70  seconds( - $Disp
1570: 6c 61 79 49 6e 74 65 72 76 61 6c 20 29 0d 0a 09  layInterval )...
1580: 09 24 45 78 69 74 46 6f 72 63 65 64 20 3d 20 24  .$ExitForced = $
1590: 66 61 6c 73 65 0d 0a 0d 0a 0d 0a 09 09 20 66 75  false........ fu
15a0: 6e 63 74 69 6f 6e 20 49 6e 69 74 20 28 24 49 6e  nction Init ($In
15b0: 70 75 74 51 75 65 75 65 29 7b 0d 0a 09 09 09 23  putQueue){.....#
15c0: 20 43 72 65 61 74 65 20 74 68 65 20 73 68 61 72   Create the shar
15d0: 65 64 20 74 68 72 65 61 64 2d 73 61 66 65 20 71  ed thread-safe q
15e0: 75 65 75 65 20 61 6e 64 20 66 69 6c 6c 20 69 74  ueue and fill it
15f0: 20 77 69 74 68 20 74 68 65 20 69 6e 70 75 74 20   with the input 
1600: 6f 62 6a 65 63 74 73 0d 0a 09 09 09 24 51 75 65  objects.....$Que
1610: 75 65 20 3d 20 5b 43 6f 6c 6c 65 63 74 69 6f 6e  ue = [Collection
1620: 73 2e 51 75 65 75 65 5d 3a 3a 53 79 6e 63 68 72  s.Queue]::Synchr
1630: 6f 6e 69 7a 65 64 28 5b 43 6f 6c 6c 65 63 74 69  onized([Collecti
1640: 6f 6e 73 2e 51 75 65 75 65 5d 40 28 24 49 6e 70  ons.Queue]@($Inp
1650: 75 74 51 75 65 75 65 29 29 0d 0a 09 09 09 24 51  utQueue)).....$Q
1660: 75 65 75 65 4c 65 6e 67 74 68 20 3d 20 24 51 75  ueueLength = $Qu
1670: 65 75 65 2e 43 6f 75 6e 74 0d 0a 09 09 09 23 20  eue.Count.....# 
1680: 44 6f 20 6e 6f 74 20 63 72 65 61 74 65 20 6d 6f  Do not create mo
1690: 72 65 20 72 75 6e 73 70 61 63 65 73 20 74 68 61  re runspaces tha
16a0: 6e 20 69 6e 70 75 74 20 6f 62 6a 65 63 74 73 0d  n input objects.
16b0: 0a 09 09 09 69 66 20 28 24 4d 61 78 50 69 70 65  ....if ($MaxPipe
16c0: 6c 69 6e 65 73 20 2d 67 74 20 24 51 75 65 75 65  lines -gt $Queue
16d0: 4c 65 6e 67 74 68 29 20 7b 24 4d 61 78 50 69 70  Length) {$MaxPip
16e0: 65 6c 69 6e 65 73 20 3d 20 24 51 75 65 75 65 4c  elines = $QueueL
16f0: 65 6e 67 74 68 7d 0d 0a 09 09 09 23 20 43 72 65  ength}.....# Cre
1700: 61 74 65 20 74 68 65 20 73 63 72 69 70 74 20 74  ate the script t
1710: 6f 20 62 65 20 72 75 6e 20 62 79 20 65 61 63 68  o be run by each
1720: 20 72 75 6e 73 70 61 63 65 0d 0a 09 09 09 24 53   runspace.....$S
1730: 63 72 69 70 74 20 20 3d 20 22 53 65 74 2d 4c 6f  cript  = "Set-Lo
1740: 63 61 74 69 6f 6e 20 27 24 50 57 44 27 3b 20 22  cation '$PWD'; "
1750: 0d 0a 09 09 09 24 53 63 72 69 70 74 20 2b 3d 20  .....$Script += 
1760: 7b 0d 0a 09 09 09 09 24 53 70 6c 69 74 4a 6f 62  {......$SplitJob
1770: 51 75 65 75 65 20 3d 20 24 28 24 49 6e 70 75 74  Queue = $($Input
1780: 29 0d 0a 09 09 09 09 26 20 7b 0d 0a 09 09 09 09  )......& {......
1790: 09 74 72 61 70 20 7b 63 6f 6e 74 69 6e 75 65 7d  .trap {continue}
17a0: 0d 0a 09 09 09 09 09 77 68 69 6c 65 20 28 24 53  .......while ($S
17b0: 70 6c 69 74 4a 6f 62 51 75 65 75 65 2e 43 6f 75  plitJobQueue.Cou
17c0: 6e 74 29 20 7b 24 53 70 6c 69 74 4a 6f 62 51 75  nt) {$SplitJobQu
17d0: 65 75 65 2e 44 65 71 75 65 75 65 28 29 7d 0d 0a  eue.Dequeue()}..
17e0: 09 09 09 09 7d 20 7c 0d 0a 09 09 09 7d 2e 54 6f  ....} |.....}.To
17f0: 53 74 72 69 6e 67 28 29 20 2b 20 24 53 63 72 69  String() + $Scri
1800: 70 74 62 6c 6f 63 6b 0d 0a 0d 0a 09 09 09 23 20  ptblock.......# 
1810: 43 72 65 61 74 65 20 61 6e 20 61 72 72 61 79 20  Create an array 
1820: 74 6f 20 6b 65 65 70 20 74 72 61 63 6b 20 6f 66  to keep track of
1830: 20 74 68 65 20 73 65 74 20 6f 66 20 70 69 70 65   the set of pipe
1840: 6c 69 6e 65 73 0d 0a 09 09 09 24 50 69 70 65 6c  lines.....$Pipel
1850: 69 6e 65 73 20 3d 20 4e 65 77 2d 4f 62 6a 65 63  ines = New-Objec
1860: 74 20 53 79 73 74 65 6d 2e 43 6f 6c 6c 65 63 74  t System.Collect
1870: 69 6f 6e 73 2e 41 72 72 61 79 4c 69 73 74 0d 0a  ions.ArrayList..
1880: 0d 0a 09 09 09 23 20 43 6f 6c 6c 65 63 74 20 74  .....# Collect t
1890: 68 65 20 66 75 6e 63 74 69 6f 6e 73 20 61 6e 64  he functions and
18a0: 20 61 6c 69 61 73 65 73 20 74 6f 20 69 6d 70 6f   aliases to impo
18b0: 72 74 0d 0a 09 09 09 24 49 6d 70 6f 72 74 49 74  rt.....$ImportIt
18c0: 65 6d 73 20 3d 20 28 24 46 75 6e 63 74 69 6f 6e  ems = ($Function
18d0: 20 2d 72 65 70 6c 61 63 65 20 27 5e 27 2c 27 46   -replace '^','F
18e0: 75 6e 63 74 69 6f 6e 3a 27 29 20 2b 0d 0a 09 09  unction:') +....
18f0: 09 09 28 24 41 6c 69 61 73 20 2d 72 65 70 6c 61  ..($Alias -repla
1900: 63 65 20 27 5e 27 2c 27 41 6c 69 61 73 3a 27 29  ce '^','Alias:')
1910: 20 7c 0d 0a 09 09 09 09 47 65 74 2d 49 74 65 6d   |......Get-Item
1920: 20 7c 20 73 65 6c 65 63 74 20 50 53 50 61 74 68   | select PSPath
1930: 2c 20 44 65 66 69 6e 69 74 69 6f 6e 0d 0a 09 09  , Definition....
1940: 09 24 73 74 6f 70 77 61 74 63 68 20 3d 20 5b 53  .$stopwatch = [S
1950: 79 73 74 65 6d 2e 44 69 61 67 6e 6f 73 74 69 63  ystem.Diagnostic
1960: 73 2e 53 74 6f 70 77 61 74 63 68 5d 3a 3a 53 74  s.Stopwatch]::St
1970: 61 72 74 4e 65 77 28 29 0d 0a 09 09 7d 0d 0a 0d  artNew()....}...
1980: 0a 09 09 66 75 6e 63 74 69 6f 6e 20 41 64 64 2d  ...function Add-
1990: 50 69 70 65 6c 69 6e 65 20 7b 0d 0a 09 09 09 23  Pipeline {.....#
19a0: 20 54 68 69 73 20 63 72 65 61 74 65 73 20 61 20   This creates a 
19b0: 6e 65 77 20 72 75 6e 73 70 61 63 65 20 61 6e 64  new runspace and
19c0: 20 73 74 61 72 74 73 20 61 6e 20 61 73 79 6e 63   starts an async
19d0: 68 72 6f 6e 6f 75 73 20 70 69 70 65 6c 69 6e 65  hronous pipeline
19e0: 20 77 69 74 68 20 6f 75 72 20 73 63 72 69 70 74   with our script
19f0: 2e 0d 0a 09 09 09 23 20 49 74 20 77 69 6c 6c 20  ......# It will 
1a00: 61 75 74 6f 6d 61 74 69 63 61 6c 6c 79 20 73 74  automatically st
1a10: 61 72 74 20 70 72 6f 63 65 73 73 69 6e 67 20 6f  art processing o
1a20: 62 6a 65 63 74 73 20 66 72 6f 6d 20 74 68 65 20  bjects from the 
1a30: 73 68 61 72 65 64 20 71 75 65 75 65 2e 0d 0a 09  shared queue....
1a40: 09 09 24 52 75 6e 73 70 61 63 65 20 3d 20 5b 53  ..$Runspace = [S
1a50: 79 73 74 65 6d 2e 4d 61 6e 61 67 65 6d 65 6e 74  ystem.Management
1a60: 2e 41 75 74 6f 6d 61 74 69 6f 6e 2e 52 75 6e 73  .Automation.Runs
1a70: 70 61 63 65 73 2e 52 75 6e 73 70 61 63 65 46 61  paces.RunspaceFa
1a80: 63 74 6f 72 79 5d 3a 3a 43 72 65 61 74 65 52 75  ctory]::CreateRu
1a90: 6e 73 70 61 63 65 28 24 48 6f 73 74 29 0d 0a 09  nspace($Host)...
1aa0: 09 09 24 52 75 6e 73 70 61 63 65 2e 4f 70 65 6e  ..$Runspace.Open
1ab0: 28 29 0d 0a 09 09 09 69 66 20 28 21 24 3f 29 20  ().....if (!$?) 
1ac0: 7b 20 74 68 72 6f 77 20 22 43 6f 75 6c 64 20 6e  { throw "Could n
1ad0: 6f 74 20 6f 70 65 6e 20 72 75 6e 73 70 61 63 65  ot open runspace
1ae0: 21 22 20 7d 0d 0a 09 09 09 24 52 75 6e 73 70 61  !" }.....$Runspa
1af0: 63 65 2e 53 65 73 73 69 6f 6e 53 74 61 74 65 50  ce.SessionStateP
1b00: 72 6f 78 79 2e 53 65 74 56 61 72 69 61 62 6c 65  roxy.SetVariable
1b10: 28 27 53 70 6c 69 74 4a 6f 62 52 75 6e 53 70 61  ('SplitJobRunSpa
1b20: 63 65 27 2c 20 24 54 72 75 65 29 0d 0a 0d 0a 09  ce', $True).....
1b30: 09 09 66 75 6e 63 74 69 6f 6e 20 43 72 65 61 74  ..function Creat
1b40: 65 50 69 70 65 6c 69 6e 65 0d 0a 09 09 09 7b 0d  ePipeline.....{.
1b50: 0a 09 09 09 09 70 61 72 61 6d 20 28 24 44 61 74  .....param ($Dat
1b60: 61 2c 20 24 53 63 72 69 70 74 62 6c 6f 63 6b 29  a, $Scriptblock)
1b70: 0d 0a 09 09 09 09 24 50 69 70 65 6c 69 6e 65 20  ......$Pipeline 
1b80: 3d 20 24 52 75 6e 73 70 61 63 65 2e 43 72 65 61  = $Runspace.Crea
1b90: 74 65 50 69 70 65 6c 69 6e 65 28 24 53 63 72 69  tePipeline($Scri
1ba0: 70 74 62 6c 6f 63 6b 29 0d 0a 09 09 09 09 69 66  ptblock)......if
1bb0: 20 28 24 44 61 74 61 29 0d 0a 09 09 09 09 7b 0d   ($Data)......{.
1bc0: 0a 09 09 09 09 09 24 4e 75 6c 6c 20 3d 20 24 50  ......$Null = $P
1bd0: 69 70 65 6c 69 6e 65 2e 49 6e 70 75 74 2e 57 72  ipeline.Input.Wr
1be0: 69 74 65 28 24 44 61 74 61 2c 20 24 54 72 75 65  ite($Data, $True
1bf0: 29 0d 0a 09 09 09 09 09 24 50 69 70 65 6c 69 6e  ).......$Pipelin
1c00: 65 2e 49 6e 70 75 74 2e 43 6c 6f 73 65 28 29 0d  e.Input.Close().
1c10: 0a 09 09 09 09 7d 0d 0a 09 09 09 09 24 4e 75 6c  .....}......$Nul
1c20: 6c 20 3d 20 24 50 69 70 65 6c 69 6e 65 2e 49 6e  l = $Pipeline.In
1c30: 76 6f 6b 65 28 29 0d 0a 09 09 09 09 24 50 69 70  voke()......$Pip
1c40: 65 6c 69 6e 65 2e 44 69 73 70 6f 73 65 28 29 0d  eline.Dispose().
1c50: 0a 09 09 09 7d 0d 0a 0d 0a 09 09 09 23 20 4f 70  ....}.......# Op
1c60: 74 69 6f 6e 61 6c 6c 79 20 69 6d 70 6f 72 74 20  tionally import 
1c70: 70 72 6f 66 69 6c 65 2c 20 76 61 72 69 61 62 6c  profile, variabl
1c80: 65 73 2c 20 66 75 6e 63 74 69 6f 6e 73 20 61 6e  es, functions an
1c90: 64 20 61 6c 69 61 73 65 73 20 66 72 6f 6d 20 74  d aliases from t
1ca0: 68 65 20 6d 61 69 6e 20 72 75 6e 73 70 61 63 65  he main runspace
1cb0: 0d 0a 09 09 09 0d 0a 09 09 09 69 66 20 28 24 55  ..........if ($U
1cc0: 73 65 50 72 6f 66 69 6c 65 29 0d 0a 09 09 09 7b  seProfile).....{
1cd0: 0d 0a 09 09 09 09 43 72 65 61 74 65 50 69 70 65  ......CreatePipe
1ce0: 6c 69 6e 65 20 2d 53 63 72 69 70 74 20 22 60 24  line -Script "`$
1cf0: 50 52 4f 46 49 4c 45 20 3d 20 27 24 50 52 4f 46  PROFILE = '$PROF
1d00: 49 4c 45 27 3b 20 2e 20 60 24 50 52 4f 46 49 4c  ILE'; . `$PROFIL
1d10: 45 22 0d 0a 09 09 09 7d 0d 0a 0d 0a 09 09 09 69  E".....}.......i
1d20: 66 20 28 24 56 61 72 69 61 62 6c 65 29 0d 0a 09  f ($Variable)...
1d30: 09 09 7b 0d 0a 09 09 09 09 66 6f 72 65 61 63 68  ..{......foreach
1d40: 20 28 24 76 61 72 20 69 6e 20 28 47 65 74 2d 56   ($var in (Get-V
1d50: 61 72 69 61 62 6c 65 20 24 56 61 72 69 61 62 6c  ariable $Variabl
1d60: 65 20 2d 53 63 6f 70 65 20 32 29 29 0d 0a 09 09  e -Scope 2))....
1d70: 09 09 7b 0d 0a 09 09 09 09 09 74 72 61 70 20 7b  ..{.......trap {
1d80: 63 6f 6e 74 69 6e 75 65 7d 0d 0a 09 09 09 09 09  continue}.......
1d90: 24 52 75 6e 73 70 61 63 65 2e 53 65 73 73 69 6f  $Runspace.Sessio
1da0: 6e 53 74 61 74 65 50 72 6f 78 79 2e 53 65 74 56  nStateProxy.SetV
1db0: 61 72 69 61 62 6c 65 28 24 76 61 72 2e 4e 61 6d  ariable($var.Nam
1dc0: 65 2c 20 24 76 61 72 2e 56 61 6c 75 65 29 0d 0a  e, $var.Value)..
1dd0: 09 09 09 09 7d 0d 0a 09 09 09 7d 0d 0a 09 09 09  ....}.....}.....
1de0: 69 66 20 28 24 49 6d 70 6f 72 74 49 74 65 6d 73  if ($ImportItems
1df0: 29 0d 0a 09 09 09 7b 0d 0a 09 09 09 09 43 72 65  ).....{......Cre
1e00: 61 74 65 50 69 70 65 6c 69 6e 65 20 24 49 6d 70  atePipeline $Imp
1e10: 6f 72 74 49 74 65 6d 73 20 7b 0d 0a 09 09 09 09  ortItems {......
1e20: 09 66 6f 72 65 61 63 68 20 28 24 69 74 65 6d 20  .foreach ($item 
1e30: 69 6e 20 24 49 6e 70 75 74 29 20 7b 4e 65 77 2d  in $Input) {New-
1e40: 49 74 65 6d 20 2d 50 61 74 68 20 24 69 74 65 6d  Item -Path $item
1e50: 2e 50 53 50 61 74 68 20 2d 56 61 6c 75 65 20 24  .PSPath -Value $
1e60: 69 74 65 6d 2e 44 65 66 69 6e 69 74 69 6f 6e 7d  item.Definition}
1e70: 0d 0a 09 09 09 09 7d 0d 0a 09 09 09 7d 0d 0a 09  ......}.....}...
1e80: 09 09 69 66 20 28 24 53 6e 61 70 49 6e 29 0d 0a  ..if ($SnapIn)..
1e90: 09 09 09 7b 0d 0a 09 09 09 09 43 72 65 61 74 65  ...{......Create
1ea0: 50 69 70 65 6c 69 6e 65 20 28 47 65 74 2d 50 53  Pipeline (Get-PS
1eb0: 53 6e 61 70 69 6e 20 24 53 6e 61 70 69 6e 20 2d  Snapin $Snapin -
1ec0: 52 65 67 69 73 74 65 72 65 64 29 20 7b 24 49 6e  Registered) {$In
1ed0: 70 75 74 20 7c 20 41 64 64 2d 50 53 53 6e 61 70  put | Add-PSSnap
1ee0: 69 6e 7d 0d 0a 09 09 09 7d 0d 0a 09 09 09 0d 0a  in}.....}.......
1ef0: 09 09 09 23 43 75 73 74 6f 6d 20 49 6e 69 74 69  ...#Custom Initi
1f00: 61 6c 69 7a 61 74 69 6f 6e 20 53 63 72 69 70 74  alization Script
1f10: 20 66 6f 72 20 73 74 61 72 74 75 70 20 6f 66 20   for startup of 
1f20: 50 69 70 65 6c 69 6e 65 20 2d 20 6e 65 65 64 73  Pipeline - needs
1f30: 20 74 6f 20 62 65 20 61 66 74 65 72 20 6f 74 68   to be after oth
1f40: 65 72 20 6f 74 68 65 72 20 69 74 65 6d 73 20 61  er other items a
1f50: 64 64 65 64 2e 0d 0a 09 09 09 69 66 20 28 24 49  dded......if ($I
1f60: 6e 69 74 69 61 6c 69 7a 65 53 63 72 69 70 74 20  nitializeScript 
1f70: 2d 6e 65 20 24 6e 75 6c 6c 29 0d 0a 09 09 09 7b  -ne $null).....{
1f80: 0d 0a 09 09 09 09 43 72 65 61 74 65 50 69 70 65  ......CreatePipe
1f90: 6c 69 6e 65 20 2d 53 63 72 69 70 74 62 6c 6f 63  line -Scriptbloc
1fa0: 6b 20 24 49 6e 69 74 69 61 6c 69 7a 65 53 63 72  k $InitializeScr
1fb0: 69 70 74 0d 0a 09 09 09 7d 0d 0a 0d 0a 09 09 09  ipt.....}.......
1fc0: 24 50 69 70 65 6c 69 6e 65 20 3d 20 24 52 75 6e  $Pipeline = $Run
1fd0: 73 70 61 63 65 2e 43 72 65 61 74 65 50 69 70 65  space.CreatePipe
1fe0: 6c 69 6e 65 28 24 53 63 72 69 70 74 29 0d 0a 09  line($Script)...
1ff0: 09 09 24 4e 75 6c 6c 20 3d 20 24 50 69 70 65 6c  ..$Null = $Pipel
2000: 69 6e 65 2e 49 6e 70 75 74 2e 57 72 69 74 65 28  ine.Input.Write(
2010: 24 51 75 65 75 65 29 0d 0a 09 09 09 24 50 69 70  $Queue).....$Pip
2020: 65 6c 69 6e 65 2e 49 6e 70 75 74 2e 43 6c 6f 73  eline.Input.Clos
2030: 65 28 29 0d 0a 09 09 09 24 50 69 70 65 6c 69 6e  e().....$Pipelin
2040: 65 2e 49 6e 76 6f 6b 65 41 73 79 6e 63 28 29 0d  e.InvokeAsync().
2050: 0a 09 09 09 24 4e 75 6c 6c 20 3d 20 24 50 69 70  ....$Null = $Pip
2060: 65 6c 69 6e 65 73 2e 41 64 64 28 24 50 69 70 65  elines.Add($Pipe
2070: 6c 69 6e 65 29 0d 0a 09 09 7d 0d 0a 0d 0a 09 09  line)....}......
2080: 66 75 6e 63 74 69 6f 6e 20 52 65 6d 6f 76 65 2d  function Remove-
2090: 50 69 70 65 6c 69 6e 65 20 28 24 50 69 70 65 6c  Pipeline ($Pipel
20a0: 69 6e 65 29 0d 0a 09 09 7b 0d 0a 09 09 09 23 20  ine)....{.....# 
20b0: 52 65 6d 6f 76 65 20 61 20 70 69 70 65 6c 69 6e  Remove a pipelin
20c0: 65 20 61 6e 64 20 72 75 6e 73 70 61 63 65 20 77  e and runspace w
20d0: 68 65 6e 20 69 74 20 69 73 20 64 6f 6e 65 0d 0a  hen it is done..
20e0: 09 09 09 24 50 69 70 65 6c 69 6e 65 2e 52 75 6e  ...$Pipeline.Run
20f0: 53 70 61 63 65 2e 43 6c 6f 73 65 41 73 79 6e 63  Space.CloseAsync
2100: 28 29 0d 0a 09 09 09 23 52 65 6d 6f 76 65 64 20  ().....#Removed 
2110: 44 69 73 70 6f 73 65 20 73 6f 20 74 68 61 74 20  Dispose so that 
2120: 53 70 6c 69 74 2d 4a 6f 62 20 63 61 6e 20 62 65  Split-Job can be
2130: 20 71 75 69 63 6b 6c 79 20 61 62 6f 72 74 65 64   quickly aborted
2140: 20 65 76 65 6e 20 69 66 20 63 75 72 72 65 6e 74   even if current
2150: 6c 79 20 72 75 6e 6e 69 6e 67 20 73 6f 6d 65 74  ly running somet
2160: 68 69 6e 67 20 77 61 69 74 69 6e 67 20 66 6f 72  hing waiting for
2170: 20 61 20 74 69 6d 65 6f 75 74 2e 0d 0a 09 09 09   a timeout......
2180: 23 41 64 64 65 64 20 63 61 6c 6c 20 74 6f 20 5b  #Added call to [
2190: 53 79 73 74 65 6d 2e 47 43 5d 3a 3a 43 6f 6c 6c  System.GC]::Coll
21a0: 65 63 74 28 29 20 61 74 20 65 6e 64 20 6f 66 20  ect() at end of 
21b0: 73 63 72 69 70 74 20 74 6f 20 66 72 65 65 20 75  script to free u
21c0: 70 20 77 68 61 74 20 6d 65 6d 6f 72 79 20 69 74  p what memory it
21d0: 20 63 61 6e 2e 0d 0a 09 09 09 23 24 50 69 70 65   can......#$Pipe
21e0: 6c 69 6e 65 2e 44 69 73 70 6f 73 65 28 29 0d 0a  line.Dispose()..
21f0: 09 09 09 24 50 69 70 65 6c 69 6e 65 73 2e 52 65  ...$Pipelines.Re
2200: 6d 6f 76 65 28 24 50 69 70 65 6c 69 6e 65 29 0d  move($Pipeline).
2210: 0a 09 09 7d 0d 0a 09 7d 0d 0a 0d 0a 09 65 6e 64  ...}...}.....end
2220: 0d 0a 09 7b 0d 0a 09 09 0d 0a 0d 0a 0d 0a 09 09  ...{............
2230: 23 20 4d 61 69 6e 0d 0a 09 09 23 20 49 6e 69 74  # Main....# Init
2240: 69 61 6c 69 7a 65 20 74 68 65 20 71 75 65 75 65  ialize the queue
2250: 20 66 72 6f 6d 20 74 68 65 20 70 69 70 65 6c 69   from the pipeli
2260: 6e 65 0d 0a 09 09 2e 20 49 6e 69 74 20 24 49 6e  ne..... Init $In
2270: 70 75 74 0d 0a 09 09 23 20 53 74 61 72 74 20 74  put....# Start t
2280: 68 65 20 70 69 70 65 6c 69 6e 65 73 0d 0a 09 09  he pipelines....
2290: 74 72 79 0d 0a 09 09 7b 0d 0a 09 09 09 77 68 69  try....{.....whi
22a0: 6c 65 20 28 24 50 69 70 65 6c 69 6e 65 73 2e 43  le ($Pipelines.C
22b0: 6f 75 6e 74 20 2d 6c 74 20 24 4d 61 78 50 69 70  ount -lt $MaxPip
22c0: 65 6c 69 6e 65 73 20 2d 61 6e 64 20 24 51 75 65  elines -and $Que
22d0: 75 65 2e 43 6f 75 6e 74 29 20 7b 41 64 64 2d 50  ue.Count) {Add-P
22e0: 69 70 65 6c 69 6e 65 7d 0d 0a 0d 0a 09 09 09 23  ipeline}.......#
22f0: 20 4c 6f 6f 70 20 74 68 72 6f 75 67 68 20 74 68   Loop through th
2300: 65 20 70 69 70 65 6c 69 6e 65 73 20 61 6e 64 20  e pipelines and 
2310: 70 61 73 73 20 74 68 65 69 72 20 6f 75 74 70 75  pass their outpu
2320: 74 20 74 6f 20 74 68 65 20 70 69 70 65 6c 69 6e  t to the pipelin
2330: 65 20 75 6e 74 69 6c 20 74 68 65 79 20 61 72 65  e until they are
2340: 20 66 69 6e 69 73 68 65 64 0d 0a 09 09 09 77 68   finished.....wh
2350: 69 6c 65 20 28 24 50 69 70 65 6c 69 6e 65 73 2e  ile ($Pipelines.
2360: 43 6f 75 6e 74 29 0d 0a 09 09 09 7b 0d 0a 09 09  Count).....{....
2370: 09 09 23 20 4f 6e 6c 79 20 75 70 64 61 74 65 20  ..# Only update 
2380: 74 68 65 20 70 72 6f 67 72 65 73 73 20 62 61 72  the progress bar
2390: 20 6f 6e 63 65 20 70 65 72 20 24 44 69 73 70 6c   once per $Displ
23a0: 61 79 49 6e 74 65 72 76 61 6c 0d 0a 09 09 09 09  ayInterval......
23b0: 69 66 20 28 2d 6e 6f 74 20 24 4e 6f 50 72 6f 67  if (-not $NoProg
23c0: 72 65 73 73 20 2d 61 6e 64 20 24 53 74 6f 70 77  ress -and $Stopw
23d0: 61 74 63 68 2e 45 6c 61 70 73 65 64 4d 69 6c 6c  atch.ElapsedMill
23e0: 69 73 65 63 6f 6e 64 73 20 2d 67 65 20 24 44 69  iseconds -ge $Di
23f0: 73 70 6c 61 79 49 6e 74 65 72 76 61 6c 29 0d 0a  splayInterval)..
2400: 09 09 09 09 7b 0d 0a 09 09 09 09 09 24 43 6f 6d  ....{.......$Com
2410: 70 6c 65 74 65 64 20 3d 20 24 51 75 65 75 65 4c  pleted = $QueueL
2420: 65 6e 67 74 68 20 2d 20 24 51 75 65 75 65 2e 43  ength - $Queue.C
2430: 6f 75 6e 74 20 2d 20 24 50 69 70 65 6c 69 6e 65  ount - $Pipeline
2440: 73 2e 63 6f 75 6e 74 0d 0a 09 09 09 09 09 24 53  s.count.......$S
2450: 74 6f 70 77 61 74 63 68 2e 52 65 73 65 74 28 29  topwatch.Reset()
2460: 0d 0a 09 09 09 09 09 24 53 74 6f 70 77 61 74 63  .......$Stopwatc
2470: 68 2e 53 74 61 72 74 28 29 0d 0a 09 09 09 09 09  h.Start().......
2480: 23 24 4c 61 73 74 55 70 64 61 74 65 20 3d 20 24  #$LastUpdate = $
2490: 73 74 6f 70 77 61 74 63 68 2e 45 6c 61 70 73 65  stopwatch.Elapse
24a0: 64 4d 69 6c 6c 69 73 65 63 6f 6e 64 73 0d 0a 09  dMilliseconds...
24b0: 09 09 09 09 24 50 65 72 63 65 6e 74 43 6f 6d 70  ....$PercentComp
24c0: 6c 65 74 65 20 3d 20 28 31 30 30 20 2d 20 5b 49  lete = (100 - [I
24d0: 6e 74 5d 28 24 51 75 65 75 65 2e 43 6f 75 6e 74  nt]($Queue.Count
24e0: 29 2f 24 51 75 65 75 65 4c 65 6e 67 74 68 2a 31  )/$QueueLength*1
24f0: 30 30 29 0d 0a 09 09 09 09 09 24 44 75 72 61 74  00).......$Durat
2500: 69 6f 6e 20 3d 20 28 47 65 74 2d 44 61 74 65 29  ion = (Get-Date)
2510: 20 2d 20 24 53 74 61 72 74 54 69 6d 65 0d 0a 09   - $StartTime...
2520: 09 09 09 09 24 44 75 72 61 74 69 6f 6e 53 74 72  ....$DurationStr
2530: 69 6e 67 20 3d 20 5b 74 69 6d 65 73 70 61 6e 5d  ing = [timespan]
2540: 3a 3a 46 72 6f 6d 53 65 63 6f 6e 64 73 28 20 5b  ::FromSeconds( [
2550: 4d 61 74 68 5d 3a 3a 46 6c 6f 6f 72 28 24 44 75  Math]::Floor($Du
2560: 72 61 74 69 6f 6e 2e 54 6f 74 61 6c 53 65 63 6f  ration.TotalSeco
2570: 6e 64 73 29 29 2e 54 6f 53 74 72 69 6e 67 28 29  nds)).ToString()
2580: 0d 0a 09 09 09 09 09 24 49 74 65 6d 73 50 65 72  .......$ItemsPer
2590: 53 65 63 6f 6e 64 20 3d 20 24 43 6f 6d 70 6c 65  Second = $Comple
25a0: 74 65 64 20 2f 20 24 44 75 72 61 74 69 6f 6e 2e  ted / $Duration.
25b0: 54 6f 74 61 6c 53 65 63 6f 6e 64 73 0d 0a 09 09  TotalSeconds....
25c0: 09 09 09 24 53 65 63 6f 6e 64 73 52 65 6d 61 69  ...$SecondsRemai
25d0: 6e 69 6e 67 20 3d 20 5b 6d 61 74 68 5d 3a 3a 52  ning = [math]::R
25e0: 6f 75 6e 64 28 28 24 51 75 65 75 65 4c 65 6e 67  ound(($QueueLeng
25f0: 74 68 20 2d 20 24 43 6f 6d 70 6c 65 74 65 64 29  th - $Completed)
2600: 2f 20 28 20 2e 7b 20 69 66 20 28 24 49 74 65 6d  / ( .{ if ($Item
2610: 73 50 65 72 53 65 63 6f 6e 64 20 2d 65 71 20 30  sPerSecond -eq 0
2620: 20 29 20 7b 20 30 2e 30 30 31 20 7d 20 65 6c 73   ) { 0.001 } els
2630: 65 20 7b 20 24 49 74 65 6d 73 50 65 72 53 65 63  e { $ItemsPerSec
2640: 6f 6e 64 7d 7d 29 29 0d 0a 09 09 09 09 09 0d 0a  ond}})).........
2650: 09 09 09 09 09 57 72 69 74 65 2d 50 72 6f 67 72  .....Write-Progr
2660: 65 73 73 20 2d 41 63 74 69 76 69 74 79 20 22 2a  ess -Activity "*
2670: 2a 20 53 70 6c 69 74 2d 4a 6f 62 20 2a 2a 20 20  * Split-Job **  
2680: 2a 50 72 65 73 73 20 45 73 63 20 74 6f 20 65 78  *Press Esc to ex
2690: 69 74 2a 20 20 4e 65 78 74 20 69 74 65 6d 3a 20  it*  Next item: 
26a0: 24 28 74 72 61 70 20 7b 63 6f 6e 74 69 6e 75 65  $(trap {continue
26b0: 7d 3b 20 69 66 20 28 24 51 75 65 75 65 2e 43 6f  }; if ($Queue.Co
26c0: 75 6e 74 29 20 7b 24 51 75 65 75 65 2e 50 65 65  unt) {$Queue.Pee
26d0: 6b 28 29 7d 29 22 20 60 0d 0a 09 09 09 09 09 09  k()})" `........
26e0: 2d 73 74 61 74 75 73 20 22 51 75 65 75 65 73 3a  -status "Queues:
26f0: 20 24 28 24 50 69 70 65 6c 69 6e 65 73 2e 43 6f   $($Pipelines.Co
2700: 75 6e 74 29 20 51 75 65 75 65 4c 65 6e 67 74 68  unt) QueueLength
2710: 3a 20 24 28 24 51 75 65 75 65 4c 65 6e 67 74 68  : $($QueueLength
2720: 29 20 53 74 61 72 74 54 69 6d 65 3a 20 24 28 24  ) StartTime: $($
2730: 53 74 61 72 74 54 69 6d 65 29 20 20 24 28 24 50  StartTime)  $($P
2740: 72 6f 67 72 65 73 73 49 6e 66 6f 29 22 20 60 0d  rogressInfo)" `.
2750: 0a 09 09 09 09 09 09 2d 63 75 72 72 65 6e 74 4f  .......-currentO
2760: 70 65 72 61 74 69 6f 6e 20 20 22 24 28 20 2e 20  peration  "$( . 
2770: 7b 20 69 66 20 28 24 45 78 69 74 46 6f 72 63 65  { if ($ExitForce
2780: 64 29 20 7b 20 27 41 62 6f 72 74 69 6e 67 20 4a  d) { 'Aborting J
2790: 6f 62 21 20 20 20 27 20 7d 7d 29 43 6f 6d 70 6c  ob!   ' }})Compl
27a0: 65 74 65 64 3a 20 24 28 24 43 6f 6d 70 6c 65 74  eted: $($Complet
27b0: 65 64 29 20 50 65 6e 64 69 6e 67 3a 20 24 28 24  ed) Pending: $($
27c0: 51 75 65 75 65 4c 65 6e 67 74 68 2d 20 28 24 51  QueueLength- ($Q
27d0: 75 65 75 65 4c 65 6e 67 74 68 2d 28 24 51 75 65  ueueLength-($Que
27e0: 75 65 2e 43 6f 75 6e 74 20 2b 20 24 50 69 70 65  ue.Count + $Pipe
27f0: 6c 69 6e 65 73 2e 43 6f 75 6e 74 29 29 29 20 52  lines.Count))) R
2800: 75 6e 54 69 6d 65 3a 20 24 28 24 44 75 72 61 74  unTime: $($Durat
2810: 69 6f 6e 53 74 72 69 6e 67 29 20 49 74 65 6d 73  ionString) Items
2820: 50 65 72 53 65 63 6f 6e 64 3a 20 24 28 5b 6d 61  PerSecond: $([ma
2830: 74 68 5d 3a 3a 72 6f 75 6e 64 28 24 49 74 65 6d  th]::round($Item
2840: 73 50 65 72 53 65 63 6f 6e 64 2c 20 33 29 29 22  sPerSecond, 3))"
2850: 60 0d 0a 09 09 09 09 09 09 2d 50 65 72 63 65 6e  `........-Percen
2860: 74 43 6f 6d 70 6c 65 74 65 20 24 50 65 72 63 65  tComplete $Perce
2870: 6e 74 43 6f 6d 70 6c 65 74 65 20 60 0d 0a 09 09  ntComplete `....
2880: 09 09 09 09 2d 49 64 20 24 50 72 6f 67 72 65 73  ....-Id $Progres
2890: 73 49 44 20 60 0d 0a 09 09 09 09 09 09 2d 53 65  sID `........-Se
28a0: 63 6f 6e 64 73 52 65 6d 61 69 6e 69 6e 67 20 24  condsRemaining $
28b0: 53 65 63 6f 6e 64 73 52 65 6d 61 69 6e 69 6e 67  SecondsRemaining
28c0: 0d 0a 09 09 09 09 7d 09 0d 0a 09 09 09 09 66 6f  ......}.......fo
28d0: 72 65 61 63 68 20 28 24 50 69 70 65 6c 69 6e 65  reach ($Pipeline
28e0: 20 69 6e 20 40 28 24 50 69 70 65 6c 69 6e 65 73   in @($Pipelines
28f0: 29 29 0d 0a 09 09 09 09 7b 0d 0a 09 09 09 09 09  ))......{.......
2900: 69 66 20 28 20 2d 6e 6f 74 20 24 50 69 70 65 6c  if ( -not $Pipel
2910: 69 6e 65 2e 4f 75 74 70 75 74 2e 45 6e 64 4f 66  ine.Output.EndOf
2920: 50 69 70 65 6c 69 6e 65 20 2d 6f 72 20 2d 6e 6f  Pipeline -or -no
2930: 74 20 24 50 69 70 65 6c 69 6e 65 2e 45 72 72 6f  t $Pipeline.Erro
2940: 72 2e 45 6e 64 4f 66 50 69 70 65 6c 69 6e 65 29  r.EndOfPipeline)
2950: 0d 0a 09 09 09 09 09 7b 0d 0a 09 09 09 09 09 09  .......{........
2960: 24 50 69 70 65 6c 69 6e 65 2e 4f 75 74 70 75 74  $Pipeline.Output
2970: 2e 4e 6f 6e 42 6c 6f 63 6b 69 6e 67 52 65 61 64  .NonBlockingRead
2980: 28 29 0d 0a 09 09 09 09 09 09 24 50 69 70 65 6c  ()........$Pipel
2990: 69 6e 65 2e 45 72 72 6f 72 2e 4e 6f 6e 42 6c 6f  ine.Error.NonBlo
29a0: 63 6b 69 6e 67 52 65 61 64 28 29 20 7c 20 25 20  ckingRead() | % 
29b0: 7b 20 57 72 69 74 65 2d 45 72 72 6f 72 20 2d 45  { Write-Error -E
29c0: 72 72 6f 72 52 65 63 6f 72 64 20 24 5f 20 7d 0d  rrorRecord $_ }.
29d0: 0a 0d 0a 09 09 09 09 09 7d 20 65 6c 73 65 0d 0a  ........} else..
29e0: 09 09 09 09 09 7b 0d 0a 09 09 09 09 09 09 23 20  .....{........# 
29f0: 50 69 70 65 6c 69 6e 65 20 68 61 73 20 73 74 6f  Pipeline has sto
2a00: 70 70 65 64 3b 20 69 66 20 74 68 65 72 65 20 77  pped; if there w
2a10: 61 73 20 61 6e 20 65 72 72 6f 72 20 73 68 6f 77  as an error show
2a20: 20 69 6e 66 6f 20 61 6e 64 20 72 65 73 74 61 72   info and restar
2a30: 74 20 69 74 09 09 09 0d 0a 09 09 09 09 09 09 69  t it...........i
2a40: 66 20 28 24 50 69 70 65 6c 69 6e 65 2e 50 69 70  f ($Pipeline.Pip
2a50: 65 6c 69 6e 65 53 74 61 74 65 49 6e 66 6f 2e 53  elineStateInfo.S
2a60: 74 61 74 65 20 2d 65 71 20 27 46 61 69 6c 65 64  tate -eq 'Failed
2a70: 27 29 0d 0a 09 09 09 09 09 09 7b 0d 0a 09 09 09  ')........{.....
2a80: 09 09 09 09 57 72 69 74 65 2d 45 72 72 6f 72 20  ....Write-Error 
2a90: 24 50 69 70 65 6c 69 6e 65 2e 50 69 70 65 6c 69  $Pipeline.Pipeli
2aa0: 6e 65 53 74 61 74 65 49 6e 66 6f 2e 52 65 61 73  neStateInfo.Reas
2ab0: 6f 6e 0d 0a 09 09 09 09 09 09 09 0d 0a 09 09 09  on..............
2ac0: 09 09 09 09 23 20 52 65 73 74 61 72 74 20 74 68  ....# Restart th
2ad0: 65 20 72 75 6e 73 70 61 63 65 0d 0a 09 09 09 09  e runspace......
2ae0: 09 09 09 69 66 20 28 24 51 75 65 75 65 2e 43 6f  ...if ($Queue.Co
2af0: 75 6e 74 20 2d 6c 74 20 24 51 75 65 75 65 4c 65  unt -lt $QueueLe
2b00: 6e 67 74 68 29 20 7b 41 64 64 2d 50 69 70 65 6c  ngth) {Add-Pipel
2b10: 69 6e 65 7d 0d 0a 09 09 09 09 09 09 7d 0d 0a 09  ine}........}...
2b20: 09 09 09 09 09 52 65 6d 6f 76 65 2d 50 69 70 65  .....Remove-Pipe
2b30: 6c 69 6e 65 20 24 50 69 70 65 6c 69 6e 65 0d 0a  line $Pipeline..
2b40: 09 09 09 09 09 7d 0d 0a 09 09 09 09 09 69 66 20  .....}.......if 
2b50: 28 20 28 28 47 65 74 2d 44 61 74 65 29 20 2d 20  ( ((Get-Date) - 
2b60: 24 53 74 61 72 74 54 69 6d 65 29 2e 54 6f 74 61  $StartTime).Tota
2b70: 6c 53 65 63 6f 6e 64 73 20 2d 67 65 20 24 4d 61  lSeconds -ge $Ma
2b80: 78 44 75 72 61 74 69 6f 6e 20 2d 61 6e 64 20 2d  xDuration -and -
2b90: 6e 6f 74 20 24 45 78 69 74 46 6f 72 63 65 64 29  not $ExitForced)
2ba0: 0d 0a 09 09 09 09 09 7b 0d 0a 09 09 09 09 09 09  .......{........
2bb0: 57 72 69 74 65 2d 57 61 72 6e 69 6e 67 20 22 41  Write-Warning "A
2bc0: 62 6f 72 74 69 6e 67 20 6a 6f 62 21 20 54 68 65  borting job! The
2bd0: 20 4d 61 78 44 75 72 61 74 69 6f 6e 20 6f 66 20   MaxDuration of 
2be0: 24 4d 61 78 44 75 72 61 74 69 6f 6e 20 73 65 63  $MaxDuration sec
2bf0: 6f 6e 64 73 20 68 61 73 20 62 65 65 6e 20 72 65  onds has been re
2c00: 61 63 68 65 64 2e 20 49 6e 70 75 74 73 20 74 68  ached. Inputs th
2c10: 61 74 20 68 61 76 65 20 6e 6f 74 20 62 65 65 6e  at have not been
2c20: 20 70 72 6f 63 65 73 73 65 64 20 77 69 6c 6c 20   processed will 
2c30: 62 65 20 73 6b 69 70 70 65 64 2e 22 0d 0a 09 09  be skipped."....
2c40: 09 09 09 09 24 45 78 69 74 46 6f 72 63 65 64 3d  ....$ExitForced=
2c50: 24 74 72 75 65 0d 0a 09 09 09 09 09 7d 0d 0a 09  $true.......}...
2c60: 09 09 09 09 0d 0a 09 09 09 09 09 69 66 20 28 24  ...........if ($
2c70: 45 78 69 74 46 6f 72 63 65 64 29 20 7b 20 24 50  ExitForced) { $P
2c80: 69 70 65 6c 69 6e 65 2e 53 74 6f 70 41 73 79 6e  ipeline.StopAsyn
2c90: 63 28 29 3b 20 52 65 6d 6f 76 65 2d 50 69 70 65  c(); Remove-Pipe
2ca0: 6c 69 6e 65 20 24 50 69 70 65 6c 69 6e 65 20 7d  line $Pipeline }
2cb0: 0d 0a 09 09 09 09 7d 0d 0a 09 09 09 09 77 68 69  ......}......whi
2cc0: 6c 65 20 28 24 48 6f 73 74 2e 55 49 2e 52 61 77  le ($Host.UI.Raw
2cd0: 55 49 2e 4b 65 79 41 76 61 69 6c 61 62 6c 65 29  UI.KeyAvailable)
2ce0: 0d 0a 09 09 09 09 7b 0d 0a 09 09 09 09 09 69 66  ......{.......if
2cf0: 20 28 24 48 6f 73 74 2e 75 69 2e 52 61 77 55 49   ($Host.ui.RawUI
2d00: 2e 52 65 61 64 4b 65 79 28 27 4e 6f 45 63 68 6f  .ReadKey('NoEcho
2d10: 2c 49 6e 63 6c 75 64 65 4b 65 79 44 6f 77 6e 2c  ,IncludeKeyDown,
2d20: 49 6e 63 6c 75 64 65 4b 65 79 55 70 27 29 2e 56  IncludeKeyUp').V
2d30: 69 72 74 75 61 6c 4b 65 79 43 6f 64 65 20 2d 65  irtualKeyCode -e
2d40: 71 20 32 37 20 2d 61 6e 64 20 21 24 45 78 69 74  q 27 -and !$Exit
2d50: 46 6f 72 63 65 64 29 0d 0a 09 09 09 09 09 7b 0d  Forced).......{.
2d60: 0a 09 09 09 09 09 09 24 51 75 65 75 65 2e 43 6c  .......$Queue.Cl
2d70: 65 61 72 28 29 3b 0d 0a 09 09 09 09 09 09 57 72  ear();........Wr
2d80: 69 74 65 2d 57 61 72 6e 69 6e 67 20 27 41 62 6f  ite-Warning 'Abo
2d90: 72 74 69 6e 67 20 6a 6f 62 21 20 45 73 63 61 70  rting job! Escap
2da0: 65 20 70 72 65 73 73 65 64 21 20 49 6e 70 75 74  e pressed! Input
2db0: 73 20 74 68 61 74 20 68 61 76 65 20 6e 6f 74 20  s that have not 
2dc0: 62 65 65 6e 20 70 72 6f 63 65 73 73 65 64 20 77  been processed w
2dd0: 69 6c 6c 20 62 65 20 73 6b 69 70 70 65 64 2e 27  ill be skipped.'
2de0: 0d 0a 09 09 09 09 09 09 24 45 78 69 74 46 6f 72  ........$ExitFor
2df0: 63 65 64 20 3d 20 24 74 72 75 65 3b 0d 0a 09 09  ced = $true;....
2e00: 09 09 09 09 23 66 6f 72 65 61 63 68 20 28 24 50  ....#foreach ($P
2e10: 69 70 65 6c 69 6e 65 20 69 6e 20 40 28 24 50 69  ipeline in @($Pi
2e20: 70 65 6c 69 6e 65 73 29 29 0d 0a 09 09 09 09 09  pelines)).......
2e30: 09 23 7b 0d 0a 09 09 09 09 09 09 23 09 24 50 69  .#{........#.$Pi
2e40: 70 65 6c 69 6e 65 2e 53 74 6f 70 41 73 79 6e 63  peline.StopAsync
2e50: 28 29 0d 0a 09 09 09 09 09 09 23 7d 0d 0a 09 09  ()........#}....
2e60: 09 09 09 7d 09 09 0d 0a 09 09 09 09 7d 0d 0a 09  ...}........}...
2e70: 09 09 09 69 66 20 28 24 50 69 70 65 6c 69 6e 65  ...if ($Pipeline
2e80: 73 2e 43 6f 75 6e 74 29 20 7b 53 74 61 72 74 2d  s.Count) {Start-
2e90: 53 6c 65 65 70 20 2d 4d 69 6c 6c 69 73 65 63 6f  Sleep -Milliseco
2ea0: 6e 64 73 20 35 30 7d 0d 0a 09 09 09 7d 0d 0a 0d  nds 50}.....}...
2eb0: 0a 09 09 09 23 43 6c 65 61 72 20 74 68 65 20 50  ....#Clear the P
2ec0: 72 6f 67 72 65 73 73 20 62 61 72 20 73 6f 20 6f  rogress bar so o
2ed0: 74 68 65 72 20 61 70 70 73 20 64 6f 6e 27 74 20  ther apps don't 
2ee0: 68 61 76 65 20 74 6f 20 6b 65 65 70 20 73 65 65  have to keep see
2ef0: 69 6e 67 20 69 74 2e 0d 0a 09 09 09 57 72 69 74  ing it......Writ
2f00: 65 2d 50 72 6f 67 72 65 73 73 20 2d 43 6f 6d 70  e-Progress -Comp
2f10: 6c 65 74 65 64 20 2d 41 63 74 69 76 69 74 79 20  leted -Activity 
2f20: 22 60 30 22 20 2d 53 74 61 74 75 73 20 22 60 30  "`0" -Status "`0
2f30: 22 0d 0a 0d 0a 09 09 09 23 20 53 69 6e 63 65 20  ".......# Since 
2f40: 72 65 66 65 72 65 6e 63 65 20 74 6f 20 44 69 73  reference to Dis
2f50: 70 6f 73 65 20 77 61 73 20 72 65 6d 6f 76 65 64  pose was removed
2f60: 2e 20 20 49 20 61 64 64 65 64 20 74 68 69 73 20  .  I added this 
2f70: 74 6f 20 74 72 79 20 74 6f 20 68 65 6c 70 20 77  to try to help w
2f80: 69 74 68 20 72 65 6c 65 61 73 69 6e 67 20 72 65  ith releasing re
2f90: 73 6f 75 72 63 65 73 20 61 73 20 70 6f 73 73 69  sources as possi
2fa0: 62 6c 65 2e 0d 0a 09 09 09 23 20 54 68 69 73 20  ble......# This 
2fb0: 6d 69 67 68 74 20 62 65 20 61 20 62 61 64 20 69  might be a bad i
2fc0: 64 65 61 2c 20 62 75 74 20 49 27 6d 20 6c 65 61  dea, but I'm lea
2fd0: 76 69 6e 67 20 69 74 20 69 6e 20 66 6f 72 20 6e  ving it in for n
2fe0: 6f 77 2e 20 28 53 74 65 70 68 65 6e 20 4d 69 6c  ow. (Stephen Mil
2ff0: 6c 73 29 0d 0a 09 09 09 5b 47 43 5d 3a 3a 43 6f  ls).....[GC]::Co
3000: 6c 6c 65 63 74 28 29 0d 0a 09 09 7d 0d 0a 09 09  llect()....}....
3010: 66 69 6e 61 6c 6c 79 0d 0a 09 09 7b 0d 0a 09 09  finally....{....
3020: 09 66 6f 72 65 61 63 68 20 28 24 50 69 70 65 6c  .foreach ($Pipel
3030: 69 6e 65 20 69 6e 20 40 28 24 50 69 70 65 6c 69  ine in @($Pipeli
3040: 6e 65 73 29 29 0d 0a 09 09 09 7b 0d 0a 09 09 09  nes)).....{.....
3050: 09 69 66 20 28 20 2d 6e 6f 74 20 24 50 69 70 65  .if ( -not $Pipe
3060: 6c 69 6e 65 2e 4f 75 74 70 75 74 2e 45 6e 64 4f  line.Output.EndO
3070: 66 50 69 70 65 6c 69 6e 65 20 2d 6f 72 20 2d 6e  fPipeline -or -n
3080: 6f 74 20 24 50 69 70 65 6c 69 6e 65 2e 45 72 72  ot $Pipeline.Err
3090: 6f 72 2e 45 6e 64 4f 66 50 69 70 65 6c 69 6e 65  or.EndOfPipeline
30a0: 29 0d 0a 09 09 09 09 7b 0d 0a 09 09 09 09 09 57  )......{.......W
30b0: 72 69 74 65 2d 57 61 72 6e 69 6e 67 20 27 50 69  rite-Warning 'Pi
30c0: 70 65 6c 69 6e 65 20 73 74 69 6c 6c 20 72 75 6e  peline still run
30d0: 69 6e 6e 67 2e 20 20 53 74 6f 70 70 69 6e 67 20  inng.  Stopping 
30e0: 41 73 79 6e 63 2e 27 0d 0a 09 09 09 09 09 24 50  Async.'.......$P
30f0: 69 70 65 6c 69 6e 65 2e 53 74 6f 70 41 73 79 6e  ipeline.StopAsyn
3100: 63 28 29 0d 0a 09 09 09 09 09 52 65 6d 6f 76 65  c().......Remove
3110: 2d 50 69 70 65 6c 69 6e 65 20 24 50 69 70 65 6c  -Pipeline $Pipel
3120: 69 6e 65 0d 0a 09 09 09 09 7d 0d 0a 09 09 09 7d  ine......}.....}
3130: 0d 0a 09 09 7d 0d 0a 09 7d 0d 0a 7d 0d 0a        ....}...}..}..