問題タブ [actor-model]

n-TransformBlocksによってリンクできるJoinBlockの代替手段を探し、そのコレクションを別のデータフローブロックに渡すために、すべてのTransformBlockソースブロックのメッセージを結合/マージします。

JoinBlockは正常に機能しますが、最大3つのソースブロックをフックするように制限されています。また、かなりの数の非効率性に悩まされています（2つのソースブロックの値型（int）でさえ結合するのが非常に遅い）。TransformBlocksからタスクを返し、すべてのTransformBlocksがタスクを完了するまで待ってから、受け入れる方法はありTask<item>ますか？

別のアイデアはありますか？結合されたアイテムコレクションを渡す前に結合する必要のあるアイテムを1〜20個持つ可能性があります。各変換ブロックは、「変換された」入力項目ごとに1つの出力項目を返すことが保証されています。

編集：要求された説明：

以前の質問の1つに従って、JoinBlocksを次のように設定しました。

私は分散システムのコースを受講しており、Scala を使用してプロジェクトを作成する必要があります。インストラクターは、Scala は複数のコアを使用して計算を行い、アクター モデルと統合しながら並列処理を使用して問題を解決するという意味で優れていると教えてくれました。

これは理論的な問題です。私は Akka を使用してアクター モデルの基本をいくつか学びました。私の質問は、プログラミング中に、さまざまなアクターが複数のコアで動作するように、ユーザーがコンパイラに詳細を提供する必要があるのか​​、それとも Scala がそれを処理して複数のコアを使用するのかということです。さまざまなアクターのコア?

簡単に言えば、私の質問は次のとおりです。Scala で Akka ライブラリを使用して複数のアクターを宣言する場合、Scala コンパイラーはマルチコア CPU パワーを自動的に使用して、コア間でさまざまなアクターを分散しますか?それとも、プログラマーはこれを行うために何らかの入力を提供する必要がありますか?

要求引数に基づいて最大並列度 1 を適用する WCF 呼び出しを取得するクリーンな方法はありますか?

次のコードを想定します。

ここでは、entityId に基づいて最大 1 つの並列呼び出しを処理したいと考えています。WCF の同時実行オプションを設定できることはわかっていますが、これは同時実行またはシングル スレッドのいずれかです。しかし、entityId ごとに単一の呼び出しが必要な場合に、操作全体に対して単一の呼び出しに設定するのは少し極端すぎるようです。

私はこれをハンドロールする必要があると思いますが、アクター モデル ライブラリを使用しない場合、ここで最善の策は何でしょうか?