一般的なC＃ラウンドロビン（パーティション/ソート）キュー

Question

誰もそのキューをブロックすることができず、キュー内のアイテムを何らかの順序で処理する必要があるアイテムのキューを処理する必要があることがよくあります。私は頻繁にこれを行うクラスを書くが、いくつかの一般的なバージョンがあるはずだと思ったが、見つけられない。

私はタイプを指定することができるキュークラスを探しています。パーティションのセレクタとキューにオブジェクトを追加できるように並べ替えるセレクタを探しています。私の注文指定子で注文された次のパーティションの最初のオブジェクト。

例えば、私はパーティション分割する方法とキューをソートする方法を指定する次のように呼び出します。

var queue = new RoundRobinQueue<Message>(
      _ => _.UserID, 
      _ => _.SendDate 
      ); 

そして、私は、メッセージのの多くを追加した後、私は私のキューやプロセスにアイテムをParallel.ForEachすることができます最も早い順にSendDateの順で次のUserになります。こうすることで、あるユーザーが遅い場合、アイテムは1つのスレッドしか取得できないため、アイテムはキューをブロックしませんが、ユーザーが1人だけの場合、彼はすべてのスレッドを取得するため、彼は唯一のパーティションです。

私はすべてを見渡しましたが、このために汎用の実装をC＃で見つけることができませんでした。何か案は？

Answer 1

System.Collections.Concurrentで定義されたクラスを見てください。一般的なConcurrentQueueだけでなく、プロデューサ - コンシューマパターンのためのより基本的なビルディングブロックもあります。

使用可能なクラスとインターフェイスは、MSDNに要約されています。