並行実行：未来対並行

Question

私は、情報のためにリモートクライアントをポーリングし、その情報をリスト形式で返す呼び出し可能コードを書きました。私はthreadpoolexecutor forループを使い、Futureは複数のリモートクライアントに対して並列にタスクを実行しています。それから、私は将来のリストをすべてaddAll（）と組み合わせ、巨大な結合リストを扱います。

私の質問は、parallelstream（）を将来のループとforループを使うより効率的に使うことです。確かにコード化するのが簡単です！もし私がそのルートに行ったら、もうthreadpoolexecutorが必要でしょうか？

ありがとうございました！

 for(SiteInfo site : active_sites) { 
      TAG_SCANNER scanr = new TAG_SCANNER(site, loggr); 
      Future<List<TagInfo>> result = threadmaker.submit(scanr); 

      //SOUND THE ALARMS 
      try { 
       alarm_tags.addAll(result.get()); 
      } catch (InterruptedException | ExecutionException e) { 
       e.printStackTrace(); 
      } 
     } 

可能なコードは？ Netbeansのは、一般parallelstreamに

active_sites.parallelstream().map((site) -> new TAG_SCANNER(site, loggr)).map((scanr) -> threadmaker.submit(scanr)).forEach((result) -> { 
      //SOUND THE ALARMS 
      try { 
       alarm_tags.addAll(result.get()); 
      } 
      catch (InterruptedException | ExecutionException e) { 
       e.printStackTrace(); 
      } 
     }); 

Answer 1

ここにはいくつかの誤解があります。まず、非同期タスクを使用してもリソースの使用率は向上しません。タスクをサブミットした直後にFuture.getを呼び出した場合は、次のタスクを実行する前にすぐに完了を待つ必要があります。

第2に、Netbeansによるコード変換ではほとんど同じコードが生成され、まだExecutorにタスクを提出しているため、並列ストリームでの提出（および待機）を行うだけで「未来対並列ストリーム」の問題ではありませんまだ実行プログラムを使用しています。あなたの最初のエラーのために、それを並行して実行するとスループットが向上するかもしれませんが、2つのミスを組み合わせて自分自身をキャンセルさせることは絶対にお勧めできません。ストリームAPIは、CPUバインドタスク用に最適化されており、CPUコアの数に一致する数のスレッドを作成し、待機中にこれらのスレッドがブロックされると新しいスレッドを生成しません。したがって、I/O操作を実行するために並列ストリームを使用するか、または一般に待機する可能性のある操作は、良い選択ではありません。また、実装で使用されるスレッドを制御することもできません。

ExecutorServiceは、リモートクライアントへの予想されるI/O帯域幅に応じて設定できます。しかし、提出直後にすべてのタスクを最初に提出し、その後すべてのタスクの完了を待つというエラーを修正する必要があります。あなたはそのためではなく、よりよい並列処理用のストリームAPIを使用することができますが、潜在的に読みやすさを向上：ここストリームAPIの使用はシーケンシャルのみにSiteInfoのリストを変換するためのものであることを

// first, submit all tasks, assuming "threadmaker" is an ExecutorService 
List<Future<List<TagInfo>>> futures=threadmaker.invokeAll(
    active_sites.stream() 
     .map(site -> new TAG_SCANNER(site, loggr)) 
     .collect(Collectors.toList()) 
); 
// now fetch all results 
for(Future<List<TagInfo>> result: futures) { 
    //SOUND THE ALARMS 
    try { 
     alarm_tags.addAll(result.get()); 
    } catch (InterruptedException | ExecutionException e) { 
     // not a recommended way of handling 
     // but I keep your code here for simplicity 
     e.printStackTrace(); 
    } 
} 

注意リストはCallable<List<TagInfo>>ですが、ループを使って同じことができます。

Answer 2

は非常に効果的に並列処理を行うことは非常にスマートなプログラマによって書かれているこれらの線に沿って何かを示唆しています。それと

、あなたが主題の専門家でない限り、このような同時実行のパッケージなど、すべての他のJavaスレッドと同じように、その後、あなたはそれを自分で書く場合は、への可能性があります：

• ラン遅くバグ
• を紹介つまりは/ etcコード

に従うことが困難/より複雑なを持っている：はい、parallelstreamを使用しています。