問題タブ [fork-join]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
1 に答える
339 参照

java - Javaでフォーク/ジョインアルゴリズムのしきい値を設定するには?

フォーク/ジョイン アルゴリズムの適切なしきい値を特定するにはどうすればよいですか? 今のところ、いくつかのしきい値で任意に再生し、結果を確認します。しかし、最適なしきい値を設定するためのガイドラインやベストプラクティスはありますか?

私の例では、1_000_000 要素の配列を使用しています。

しきい値 von 100_000 を次のように変更します。

私にもっとパフォーマンスを与えてください。しかし、これは単なる任意のテストです。

誰かが私を助けることができますか?:)

0 投票する
1 に答える
607 参照

java - fork() は最終的に計算を呼び出しますか?

私の理解では、別のスレッドを作成し、別のスレッドで compute() を実行します。join は再帰的に取得した結果をフェッチします。

fork()電話かどうか知りたいcompute()です。前もって感謝します。

0 投票する
1 に答える
118 参照

java - asyncMode とはどういう意味ですか?

このjavadocから直接:

このクラスは、Runnable および Callable の adapt メソッドを提供します。これは、ForkJoinTask の実行を他の種類のタスクと混合する場合に使用できます。すべてのタスクがこの形式の場合、asyncMode で構築されたプールの使用を検討してください。

asyncModeこの文脈では、実際にはどういう意味ですか?でプールを構築するにはどうすればよいasyncModeですか?

0 投票する
1 に答える
667 参照

java - ForkJoinPool クラスの Execute() メソッド

これについてのAPIの説明は次のとおりです。

スレッド、Executor 実装の裁量で。

ForkJoinPool は既に ExecutorService の実装ですか? 彼らは何を話している?このようなメソッドの動作を知るにはどうすればよいですか?

0 投票する
1 に答える
1390 参照

java - ForkJoinTask 完了ハンドラー

私はJavaのForkJoinTask.

JavaFutureTaskはテンプレート メソッドを提供しますdone()このメソッドをオーバーライドすると、「完了ハンドラの登録」が可能になります

の完了ハンドラを登録することは可能ForkJoinTaskですか?

アプリケーションでブロッキング スレッドを使用したくないので質問していますが、result = ForkJoinPool.invoke(myForkJoinTask)またはの呼び出しを介して計算結果を取得するとすぐに、アプリケーションでブロッキング スレッドが使用されますresult = ForkJoinPool.submit(myForkJoinTask).get()

0 投票する
1 に答える
4210 参照

node.js - Fork を使用して子から親にエラーを送信する

私は以下のコードを持っています

pChild.js からスローされた親のエラーを処理してプロセスを強制終了するにはどうすればよいですか?

0 投票する
2 に答える
47 参照

java - compute() で 2 つ以上の RecursiveActionTask を呼び出す

次のコードで多くの RecursiveAction を呼び出すことの欠点は何ですか?

class RecursiveActionThing extends RecursiveAction {

}

これまでのところ、2 つのタスクの呼び出ししか見ていないため、上記の呼び出しを実行すると、これらすべてのタスクを作成する際に大きなオーバーヘッドが発生する可能性がありますが、varargs をパラメーターとして配置することでそれが許可されるのはなぜですか? 特定の状況で役立つかもしれませんか?どれ?前もって感謝します。

0 投票する
1 に答える
1627 参照

java - 数千のスレッドを作成する ForkJoinPool

問題を示す簡単なテスト:

このサンプルでは、​​単純に数値を数えて CPU に負荷をかける RecursiveTask を作成します。着信範囲を再帰的に 10 の部分に分割し、部分のサイズが 1000 未満または再帰の「深さ」が 10 を超えると、数値のカウントを開始します。

compute() メソッドには 3 つのケースがコメントされています。違いは、サブタスクをフォークする順序のみです。サブタスクをフォークする順序によって、最終的なスレッドの数が異なります。私のシステムでは、最初のケースでは 3000 以上のスレッドが作成され、2 番目と 3 番目のケースでは 4 つのスレッドが作成されます。

質問: 違いは何ですか? このフレームワークをうまく使用するには、その内部構造を知る必要がありますか?

0 投票する
5 に答える
571 参照

java - シングル プロセッサでの Java fork Join フレームワークの使用

fj JAVA フレームワークを使い始めました。
私が理解しているように、アルゴリズム計算のような大きなタスクを分割し、それを小さなスレッドに分割するだけです。
問題は、このフレームワークをシングル プロセッサ マシンで使用する価値があるかどうかです。
ありがとう

0 投票する
0 に答える
215 参照

mule - ミュールで要求応答ルーターを使用した場合の例外を処理する方法

フローで次の fork と join パターンを使用しています。並列処理は問題なく動作します。ただし、例外処理に問題があります。ルーターの VM 応答インバウンド エンドポイントで発生する処理の例外戦略を実装したいと考えています。ただし、キャッチ例外戦略ブロック内から応答に書き込もうとすると、何も起こらないようです。例外が発生した場合、catch ブロックからログ ステートメントを確認できますが、ブラウザの応答がハングするだけです。提案してください。