複雑なオブジェクトを作成するためのステップを並列化する方法は？

Question

class MyItem { 
    private param1, param2, param3; 
} 

MyItem item = new MyItem(); 

computeParam1(item); 
computeParam2(item); 
computeParam3(item); 
waitForAllParamsToBeSet(); 

各ステップは互いに独立しており、各ステップは最終結果としてオブジェクトにパラメタを書き込む。 メソッドはロジックとは全く異なり、再帰はありません。

可能であれば、これらのステップをどのように並列化できますか？

Answer 1

すべてcomputeParamX()は1つのMyItem引数を受け入れると、ボイドリターンを持っているとして、彼らはConsumer<MyItem>の署名を持っています。次のようにだからあなたは、並列ストリームの.forEach()でそれらを呼び出して、その実行を並列化することができます.forEach()として

final MyItem item = new MyItem(); 
Stream.<Consumer<MyItem>>of(this::computeParam1, this::computeParam2, this::computeParam3) 
      .parallel() 
      .forEach(c -> c.accept(item)); 

を端末操作である、それは戻った後、あなたが安全にitemオブジェクトを使用することができますので、それは、すべての操作が完了するまでブロックします。

Answer 2

Futuresを開始してから、結果を待ってから割り当ててください。

Future<Type1> item1 = ComputeParam1(); 
Future<Type2> item2 = ComputeParam2(); 
Future<Type3> item2 = ComputeParam3(); 

MyItem item = new MyItem(); 

assignParam1(item1.get()); 
assignParam2(item2.get()); 
assignParam3(item3.get()); 

Answer 3

のJava 8では、あなたは、単に次のようなタスクのあなたのコレクションを作成することができます。https：：

Collection<Runnable> tasks = Arrays.asList(
    () -> System.out.println("Compute param1"), 
    () -> System.out.println("Compute param2"), 
    () -> System.out.println("Compute param3") 
); 

が続いて使用した場合でも、より多くの春便利な機能を、だパラレル

tasks.parallelStream().forEach(Runnable::run);