fork-join

1熱

1答えて

50,000個のオブジェクトのコレクションを考えてみましょう。各オブジェクトは、doWork（）メソッドを使用して、反復ごとに10倍の2倍を生成します。それぞれ50,000個のオブジェクトを処理する連続whileループがあり、はdoWork（）を呼び出します。この後、作成された10個の2倍のそれぞれをprocess（）を呼び出して処理する必要があります。 whileループ内の最後のステップ

0熱

1答えて

並列処理のためのフォーク結合パターンmule esb throw NullPointer例外

バッチで並列処理を実現するためにfork-joinパターンを使用しています。私は、次の質問を参照取るている：私は私の入力フォルダに非常に多くのファイルを持っていますが、私は、並列処理を実現する必要があるため Mule File Inbound Flow : Control Number of threads を。したがって、このパターンを使用することを考えました。ここに私の設定フローがどのように

3熱

1答えて

パラメータのリストが異なる同じ汎用workflow.xmlを使用する3つの異なるジョブをforkする方法はありますか？

私はハーフープエコシステムの初心者です。私は同じ一般的なworkflow.xmlファイルから呼び出すが、サブワークフローのそれぞれに異なるパラメータを渡す3つの異なるジョブをforkしようとしています。サブワークフロー： <?xml version="1.0" encoding="UTF-8"?> <workflow-app xmlns="uri:oozie:workflow:0.4" nam

2熱

1答えて

フォーク結合スレッドプールの設定

フォーク結合スレッドプールの使用に関する簡単な質問があります。ここで私が使用しているものの短い例があります： executor = "fork-join-executor" # Configuration for the fork join pool fork-join-executor { # Min number of threads to cap factor-

1熱

1答えて

フォークジョイン：すべてのサブタスクをフォークするか、現在のスレッドに1つ残す

フォークジョインの仕組みの詳細を理解しようとしています。ウィキペディアには、左半分がフォークされ、右半分が現在のスレッドによって処理されるmerge-sortの例があります。 mergesort(A, lo, hi): if lo < hi: // at least one element of input mid = ⌊(hi - lo)/2⌋ fo

0熱

1答えて

fpga上のフォーク結合アルゴリズム

fpgaでフォーク結合問題を転送したいとします。メモリコンポーネントにアクセスする小さなコンポーネント（> 100）が数多く存在するため、入力データ（32ビットベクタ数）を少量のサイクル（〜50）で処理し、相互作用することなく処理します。別のメモリにアクセスするためのデータ。相互接続に関して、従来のバスソリューションを使用する必要があるか、システムレベルツール（Qsys altera）で提供さ

1熱

2答えて

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

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

-1熱

1答えて

共通のForkJoinPoolがすべてのコアを使用しようとしないのはなぜですか？

私はスレッドプールサイズがCPUコアの数に結びついている理由を理解していますが、ForkJoinThreadの設計者はデフォルトで# of cpu cores - 1スレッドを使用するのはなぜですか？なぜ-1？私が構築していた場合、私自身ForkJoinPool（共通インスタンスを使用していない）、およびmainスレッドは、それはいくつかの結果を返すのを待って、プールでブロックされている、私はR

1熱

1答えて

非デーモン化フォーク/結合プール

非デーモン化フォーク/結合プールの作成方法は？私は、このような方法で、プールを作成した場合： ForkJoinPool pool = ForkJoinPool.commonPool() をするとき、私のプログラム終了それは、それを防止するための適切な方法は何か、すべてのタスクを停止されますか？

5熱

1答えて

forkJoinから返されたObservableの登録を解除するには？

私のAngular2-typescriptアプリでは、forkJoinを使用して、すべての並列HTTP呼び出しが行われた後にObservableを返すだけです。問題：サブスクリプションのコールバックは無期限にここでを実行され続けては、私のコードです： http.service import {Http} from "@angular/http"; constructor (private