ハッシュ/シャードされたActionBlocks

Question

私は並列処理が必要な特定のアイテムのフローが一定であるため、TPL Dataflowを使用しています。キャッチは、同じキー（ディクショナリに似ています）を共有するアイテムは、FIFO順で処理され、互いに平行ではなく（異なる値を持つ他のアイテムと平行になることがあります）ということです。作業が行われて

は、私の解決策はありません並列処理とEnvironment.ProcessorCountのActionBlock<T> Sサイズの配列を作成し、キーのGetHashCode値に応じて、それらに投稿することだったので、最小限の非同期ロックを結合した非常にCPUです。

作成：

_actionBlocks = new ActionBlock<Item>[Environment.ProcessorCount]; 
for (int i = 0; i < _actionBlocks.Length; i++) 
{ 
    _actionBlocks[i] = new ActionBlock<Item>(_ => ProcessItemAsync(_)); 
} 

使用法：

bool ProcessItem(Key key, Item item) 
{ 
    var actionBlock = _actionBlocks[(uint)key.GetHashCode() % _actionBlocks.Length]; 
    return actionBlock.Post(item); 
} 

だから、私の質問があり、これは私の問題に最適なソリューションですか？パフォーマンス/スケーラビリティが傷つきますか？何か不足していますか？

Answer 1

私はあなたのアプローチが合理的だと思っています。

悪いディストリビューションに対してより良い保護をしたい場合は、をすべてのブロックで共有することで、より多くの数のActionBlockを使用し、合計同時実行レベルを制限することができます。そのようなスケジューラin ParallelExtensionsExtrasまたはon MSDNを見つけることができます。