プールと順次処理を使用したマルチスレッド

Question

私はJava 8でコーディングしており、JPAを使用してさらに処理するためにHTTPリクエストを介して取得するデータを持っています。 JPA（EclipseLink）が逐次処理を必要とするため、処理が失敗するマルチスレッドの考え方。 REST-テンプレートでHTTPリクエストがcontent=response.getBody().getDataChunk()のようなものは、単一のHTTPリクエストを取得して取得され、約50-70ms、が、約1.000s要求の照会をとる==>

1. スタート時のHTTPをたくさんかかりますマルチスレッド
2. 保存-queryingクエリ -
3. スタック内の最も可能性が高いが、スタックから単一のデータ要素を取得し、プロセスは

しかし、私は詳細をコーディングする方法について見当もつかない。つまり、スタックとしてどのようなオブジェクトを使うべきですか？どのようにステップ3の進行中の処理を開始するには？ Thread.join()？さらに、複数のスレッドの量をどのように制限するか。 2または3？ ExecutorService.newCachedPool(3)（またはそれに類するもの）Hmmm ...

正しく行う方法は？この特定のパターンのリンクはありますか？

Answer 1

私は最近、これを達成するために次のようなコードを使用しました。私はあなたがあなたのために働くためにそれを適応させることができると確信しています

ExecutorService executor = Executors.newCachedThreadPool() 
List<MyType> results = urls.stream().map((String url)->executor.submit(()-> { 

     return url.substring(2); // retrieve the page and do something with it 

    })) 
    .collect(Collectors.toList()) // this makes sure all urls are submitted before processing the results 
    .stream().map(future -> { 
     try { 
      return future.get(); 
     } catch (InterruptedException | ExecutionException e) { 
      e.printStackTrace(); 
      return "failed"; // or some other value indicating failure 
     } 
    }).collect(Collectors.toList(); 

これは、複数のスレッドを並行して実行するためのエグゼキュータサービスを最初に作成することによって機能します。その後、URLのリストを取得し、それぞれをexecutorに送信して、上位ラムダで処理されます。

この後、すべての結果を収集し、Futureのオブジェクトを実際の値の下のラムダに変換します。