質問編集履歴

試したことの追記

2018/11/07 09:26

投稿

kmyzr

スコア305

test CHANGED Viewed

	@@ -1 +1 @@
1	- PowerShellで非同期処理でのデータの追~~記(+=)~~が~~しばしば~~無視されるの~~を回避~~したい
1	+ PowerShellで非同期処理での ref変数へのデータ追加が無視される事があるのですが確実にref変数へのデータ追加は出来ないのでしょうか?

test CHANGED Viewed

@@ -2,7 +2,7 @@
-非同期で実行した処理結果を参照渡しの変数にまとめたい
+非同期で実行した処理結果を参照渡しの変数に追加
@@ -10,7 +10,7 @@
-しばしばデータの追記がされていないことがある上に
+データの追加がされていないことがある上に
 エラーも発生しない
@@ -412,7 +412,197 @@
 ひとまず `ref`つかっての受け取りは諦めて
-　処理完了後にシリアル処理で戻り値を順に変数に格納しようと思っています。
+　処理完了後にシリアル処理で戻り値を順に変数に格納~~しようと思っています。~~しました。
+```powershell
+function _New_MultiThread()
+{
+[OutputType([_MultiThread])]
+    $Thread = New-Object _MultiThread($host)
+    return $Thread
+}
+#検索対象データの読み込み
+$_Sarch_List_Read = {
+    Param
+    (
+        # 読み込む二次元配列
+        [Parameter(Mandatory,
+                    Position=0)]
+        $Ary,
+        # 読み込み開始位置
+        [Parameter(Mandatory,
+                    Position=1)]
+        [int]
+        $Start,
+        # 読み込み終了位置
+        [Parameter(Mandatory,
+                    Position=2)]
+        [int]
+        $End
+    )
+    for ($i = $Start; $i -le $End; $i++)
+    {
+        $CSV_Data = New-Object psobject | select -Property No,Category,Type,PutName,ListPrice,Purchase,PrimeCost,SellingPrice,Maker,DisplayOrderNo,EquipmentName,CharacterSymbol
+        $CSV_Data.No = $Ary[$i,1]
+        $CSV_Data.Category = $Ary[$i,2]
+        $CSV_Data.Type = $Ary[$i,3]
+        $CSV_Data.PutName = $Ary[$i,4]
+        $CSV_Data.ListPrice = $Ary[$i,5]
+        $CSV_Data.Purchase = $Ary[$i,6]
+        $CSV_Data.PrimeCost = $Ary[$i,7]
+        $CSV_Data.SellingPrice = $Ary[$i,8]
+        $CSV_Data.Maker = $Ary[$i,9]
+        $CSV_Data.DisplayOrderNo = $Ary[$i,10]
+        $CSV_Data.EquipmentName = $Ary[$i,11]
+        $CSV_Data.CharacterSymbol = $Ary[$i,12]
+        $CSV_Data
+    }
+}
+# 20000 x 12 の配列を作成 元がExcelから持ってきてるので 添え字は1から始まりと仮定する
+$Ary = New-Object -TypeName 'System.Object[,]' -ArgumentList 20001,13
+$i = 0
+# 適当にデータ代入
+foreach ($item in $Ary)
+{
+    $_ = $i
+    $i++
+}
+    $MultiThread = _New_MultiThread
+Write-Host "検索テーブルを読み込んでいます..."
+$Max = $Ary.GetUpperBound(0)
+Write-host "対象データ行数 = $($Max)"
+$Step = 2000
+for ($i = 1; $i -le $Max; $i+=$Step)
+{
+    if ($($i + $Step - 1) -le $Max)
+    {
+        $End = $($i + $Step - 1)
+    }
+    else
+    {
+        $End = $Max
+    }
+    $MultiThread.AddThread($_Sarch_List_Read,[ordered]@{
+        Ary = $Ary
+        Start = $i
+        End = $End
+    })
+}
+while (!($MultiThread.AllCompleted)){}
+$Search = @($MultiThread.GetResult() | foreach {$_})
+$MultiThread.Dispose()
+Write-host "登録されたデータ数 = $($Search.Count)"
+```