c＃タスクマルチキュー調整

Question

異なるタスクキューを維持する必要がある環境が必要です。それぞれのキューに対して、実行可能な並行スレッドの数を定義する必要があります。このようなもの：

• キュー1 - > 3スレッド;
• キュー2 - > 6スレッド。

種類のタスクシステム。私は自分自身で、1年以上にわたって正常に機能する普通の古いC＃コード（別名System.Threading.Thread、ロックとキュー）を実装しています。しかし、私はTaskFactoryとTaskSchedulerの不思議について記事を読んでいますが、.NETで組み込みのクラスを使ってこのことを可能にしていることについてはわかりましたが、これを実証するための例は見つかりませんでした。私はそれを試してみて、今働いているかどうかを今見ているものと比較して、それがあればそれを置き換えてみたい。

キュー＃1が実行されていてもキュー＃2を対象とするアイテムが即座に実行された場合、guaranteeを取得できる限り、キューごとに並列スレッドの数を制限または設定する必要はありません。全負荷時。

だから、私の質問です.net4以上のものがあります。誰かが私にサンプルを指すことができますか？私は1週間に1つを探していて、関連性のあるものを得ることに失敗しました。

Answer 1

this exampleで説明したLimitedConcurrencyLevelTask​​Schedulerを作成するか、優先度スケジューラhereを参照してください。

Answer 2

これは実際にはTPLと新しいコレクションSystem.Collections.Concurrentを使用するとかなり簡単です。

お客様のニーズに合わせて、BlockingCollection<T>をお勧めします。デフォルトでは、ConcurrentQueue<T>を基になるストアとして使用します。これは、必要なものに最適です。

var queue = new BlockingCollection<Message>(); 

それらのメッセージに取り組んでいくつかのコードを設定して、並列に何を実行することができます制御するには、このように簡単です：

//Set max parallel Tasks 
var options = new ParallelOptions 
{ 
    MaxDegreeOfParallelism = 10 
}; 

Parallel.ForEach(queue.GetConsumingEnumerable(), options, msg => 
{ 
    //Do some stuff with this message 
}); 

だから何がここで起こっていますか？まあ...

GetConsumingEnumerable()の呼び出しは、実際には何かが消費するまでqueueにブロックされます。これは、新しい作業を行う準備ができていることを知らせるために余分なコードが必要ないため、素晴らしいことです。むしろ、queueがいっぱいになると、あなたの（匿名）代理人の新しいタスクがアイテムで開始されます。

ParallelOptionsオブジェクトを使用すると、Parallel.ForEachの動作を制御できます。この場合、あなたは一度に10以上のタスクを実行することを決して望んでいません。 Tasks！= Threadsに注意することが重要です。細部は暗いですが、言うまでもなく、ボンネットの下では多くの最適化が行われています。すべてのプラグイン可能な心ですが、それは心がかすかなものではありません。

私はここでは説明していない多くの詳細は明らかですが、うまくいけば、タスクパラレルライブラリを使用すると、どのようにシンプルで表現力豊かなのかが分かります。