forkjoinpool

1熱

2答えて

が、それはいつものExecutorServiceのようForkJoinPoolを使用することが有益である

のは、私はそのようなコードがあるとしましょう：代わりに、コンストラクタでThreadPoolExecutorを渡すので、私はForkJoinPoolを使用する場合 class Foo { private final ExecutorService executor; public Foo(ExecutorService executor) { this.execu

1熱

2答えて

すべてのCPUコアを使用していないJava ForkJoinPool

仮想壁のノードで次のコードを実行しています。ノードには32個のIntel Xeon E7/E5コアと128GBのRAMがあります。 CPUの使用状況を監視すると、ノードは完全に強く動作していないことがわかります。この問題は、ノードサイズのために、ほとんどのフォーク結合問題とは異なります。ノードは複数のコアに20％+ CPU負荷を持ち、並列性の兆候を示すこともありますが、より多くのリソースを使用でき

1熱

2答えて

ForkJoinPoolは膨大な量の作業者を作成します

私はForkJoinPoolを使用してタスクを並列に実行します。私のプログラムのログアウトを見ると、ForkJoinPoolは自分のタスクを実行するために膨大な量の作業者を作成しているようです（このようなログエントリがあります：05 Apr 2016 11:39:18,678 [ForkJoinPool-2-worker-2493] <message>）。その後、私はForkJoinPoolで構

1熱

1答えて

複数のフォークを使用してタスクを分割するクラスを結合する、良い方法ですか？

私の仕事では、非常に大きなテキストファイル（〜6800 kb）を解析する小さなJavaアプリケーションを開発する必要があります。そのため、それをさらに最適化して処理を進めようとしています。最初のフォークタスクとして等号（=）を使用し、2番目のフォークタスクを使用してコンマでいくつかの計算を分割する。これは、単一アプリケーションのために複数のフォークタスクを備えた良好なパフォーマンスにつながりますか

6熱

1答えて

デフォルトのスレッド数を超えるJavaストリームをどのように処理できますか？

デフォルトでは、Javaストリームはデフォルトのパラメータで構築されたcommon thread poolによって処理されます。 another questionで回答されているように、カスタムプールを指定するか、java.util.concurrent.ForkJoinPool.common.parallelismシステムパラメータを設定することによって、これらのデフォルトを調整できます。しか

5熱

2答えて

並列ストリームを連続して呼び出すと、すべての以前の操作が順次行われます。

私はかなりのデータセットを持っていますが、遅いがクリーンなメソッドを呼び出し、最初のメソッドの結果に副作用を伴うファーストメソッドを呼び出したい。私は中間結果に興味がないので、私はそれらを収集したくないです。明白な解決策は、パラレルストリームを作成し、スローコールを行い、ストリームを再びシーケンシャルにし、高速コールを行うことです。問題は、すべてのコードが単一スレッドで実行されていることです。実

8熱

1答えて

Java 8の並列ストリームとThreadLocal

Java 8の並列ストリームでThreadLocal値をコピーするにはどうすればいいですか？我々は考えるのであれば、この： public class ThreadLocalTest { public static void main(String[] args) { ThreadContext.set("MAIN"); System.out.printf

6熱

2答えて

シングルスレッドのForkJoinPoolを設定するには？

実行スレッドを1つ使用するようにForkJoinPoolを設定することはできますか？私はForkJoinPoolの中にRandomを呼び出すコードを実行しています。それが実行されるたびに、私は異なるランタイム動作になり、回帰を調べることが難しくなります。 "debug"と "release"モードを提供するコードベースが欲しいです。「デバッグ」モードでは、固定シードでRandomを構成し、単一