teratail
回答率
85.46%
質問するログイン新規登録
トップC#に関する質問Parallel.ForEachでのawaitは可能でしょうか

編集履歴

回答編集履歴

2

追記

2020/01/15 04:27

投稿

退会済みユーザー
test CHANGED
@@ -3,3 +3,173 @@
3
3
 
4
4
 
5
5
  (UI への応答性を高めるためのバックグラウンド処理をしたいのか、マルチコアを利用して処理時間の短縮を図りたいのか目的が分かりません。なんとなく見当違いのことのように思いますが、それはとりあえず置いときます)
6
+
7
+
8
+
9
+ **【追記】**
10
+
11
+
12
+
13
+ 上に書いたことを検証してみました。
14
+
15
+
16
+
17
+ > listのデータに対して順序にかかわらず上限のある並列数(1～)で実行したい。システム全体でのスレッドの上限があるため、極力節約したい。
18
+
19
+
20
+
21
+ その目的のために await を使う意味が分かりません。ParallelOptions.MaxDegreeOfParallelism を設定して、普通に以下のコードのようにすれば上記の目的は果たせるはずですが？
22
+
23
+
24
+
25
+ ```
26
+
27
+ var list = Enumerable.Range(1, 30).ToList();
28
+
29
+ ParallelOptions option = new ParallelOptions();
30
+
31
+ option.MaxDegreeOfParallelism = 2;
32
+
33
+ Parallel.ForEach(list, option, i =>
34
+
35
+ {
36
+
37
+ Console.WriteLine($"Processing {i} on thread {Thread.CurrentThread.ManagedThreadId}");
38
+
39
+ });
40
+
41
+ ```
42
+
43
+
44
+
45
+ 上記のコード（MaxDegreeOfParallelism は 2 に制限）の実行結果は以下の通りとなります。質問者さんのコードでは 10 に制限しているように見えますが、スレッドの数はそのようになりませんか？
46
+
47
+
48
+
49
+ Processing 1 on thread 1
50
+
51
+ Processing 16 on thread 3
52
+
53
+ Processing 17 on thread 3
54
+
55
+ Processing 18 on thread 3
56
+
57
+ Processing 19 on thread 3
58
+
59
+ Processing 20 on thread 3
60
+
61
+ Processing 21 on thread 3
62
+
63
+ Processing 22 on thread 3
64
+
65
+ Processing 23 on thread 3
66
+
67
+ Processing 24 on thread 3
68
+
69
+ Processing 25 on thread 3
70
+
71
+ Processing 26 on thread 3
72
+
73
+ Processing 27 on thread 3
74
+
75
+ Processing 28 on thread 3
76
+
77
+ Processing 29 on thread 3
78
+
79
+ Processing 30 on thread 3
80
+
81
+ Processing 4 on thread 3
82
+
83
+ Processing 5 on thread 3
84
+
85
+ Processing 6 on thread 3
86
+
87
+ Processing 7 on thread 3
88
+
89
+ Processing 8 on thread 3
90
+
91
+ Processing 9 on thread 3
92
+
93
+ Processing 10 on thread 3
94
+
95
+ Processing 11 on thread 3
96
+
97
+ Processing 12 on thread 3
98
+
99
+ Processing 13 on thread 3
100
+
101
+ Processing 14 on thread 3
102
+
103
+ Processing 2 on thread 1
104
+
105
+ Processing 3 on thread 1
106
+
107
+ Processing 15 on thread 3
108
+
109
+
110
+
111
+
112
+
113
+ ちなみに、ParallelOptions を設定しない場合は以下のようになります。
114
+
115
+
116
+
117
+ Processing 1 on thread 1
118
+
119
+ Processing 2 on thread 1
120
+
121
+ Processing 16 on thread 7
122
+
123
+ Processing 7 on thread 4
124
+
125
+ Processing 8 on thread 4
126
+
127
+ Processing 9 on thread 4
128
+
129
+ Processing 13 on thread 6
130
+
131
+ Processing 14 on thread 6
132
+
133
+ Processing 15 on thread 6
134
+
135
+ Processing 19 on thread 9
136
+
137
+ Processing 4 on thread 3
138
+
139
+ Processing 10 on thread 5
140
+
141
+ Processing 26 on thread 5
142
+
143
+ Processing 27 on thread 5
144
+
145
+ Processing 28 on thread 5
146
+
147
+ Processing 29 on thread 5
148
+
149
+ Processing 30 on thread 5
150
+
151
+ Processing 22 on thread 8
152
+
153
+ Processing 11 on thread 4
154
+
155
+ Processing 20 on thread 6
156
+
157
+ Processing 25 on thread 10
158
+
159
+ Processing 3 on thread 1
160
+
161
+ Processing 17 on thread 7
162
+
163
+ Processing 18 on thread 7
164
+
165
+ Processing 21 on thread 6
166
+
167
+ Processing 12 on thread 4
168
+
169
+ Processing 5 on thread 3
170
+
171
+ Processing 6 on thread 3
172
+
173
+ Processing 23 on thread 9
174
+
175
+ Processing 24 on thread 9

1

追記

2020/01/15 04:27

投稿

退会済みユーザー
test CHANGED
@@ -1,4 +1,4 @@
1
- Parallel.ForEach, Parallel.For メソッドのオーバロードの中には引数に ParallelOptions を取るものがあるので、その MaxDegreeOfParallelism プロパティを使って望むことはできませんか？
1
+ Parallel.ForEach, Parallel.For メソッドのオーバロードの中には引数に ParallelOptions を取るものがあるので、その MaxDegreeOfParallelism プロパティを使って望むこと (上限のある並列数で実行) はできませんか？
2
2
 
3
3
 
4
4