scala - 並列コレクションで .seq を呼び出すと、すべてのスレッドが確実に結合されますか?

Question

次のように、 を呼び出すコレクションがあります.par。

myCollection.par.map(element => longRunningOperation(element)).seq
println("after map")

println を呼び出す.seq前に、続行する前にすべてのスレッドが結合され、すべてのマップが完了することを保証しますか?

Answer 1

map操作が呼び出されると、ワーカー スレッドが起動されます。それらはすべて、map操作が完了する前にフレームワークによって結合されます。呼び出すまでに、seq実行中のワーカー スレッドはもうありません。

Answer 2

はい、そうなります。.seq実際、最後 に電話する必要はありません。

このような質問に答える簡単な方法は、副作用がない場合、並列コレクションは非並列コレクションとまったく同じセマンティクスを持つことを覚えておくことです。longRunningOperation のコードに目に見える副作用がない限り、コードが並列で実行されていることを確認できる唯一の方法は、プロセッサの使用率をチェックすることです。