Могу предложить такой вариант:
class Program
{
private static readonly TaskScheduler importantTaskScheduler = new LimitedConcurrencyLevelTaskScheduler(1);
private static readonly TaskScheduler otherTaskScheduler = new LimitedConcurrencyLevelTaskScheduler(1);
static void Main(string[] args)
{
var items = new[]
{
new KeyValuePair<String, Object>("1", "Value 1.1"),
new KeyValuePair<String, Object>("2", "Value 2.1"),
new KeyValuePair<String, Object>("ImportantKey", "Value 3.1"),
new KeyValuePair<String, Object>("1", "Value 1.2"),
new KeyValuePair<String, Object>("2", "Value 2.2"),
new KeyValuePair<String, Object>("ImportantKey", "Value 3.2"),
new KeyValuePair<String, Object>("1", "Value 1.3"),
new KeyValuePair<String, Object>("2", "Value 2.3"),
new KeyValuePair<String, Object>("ImportantKey", "Value 3.3")
};
foreach (var keyValuePair in items)
{
Process(keyValuePair);
}
Console.ReadKey();
}
private static void Process(KeyValuePair<String, Object> pair)
{
if (pair.Key.Equals("ImportantKey"))
{
Task.Factory.StartNew(ImportantHandler, pair.Value, CancellationToken.None, TaskCreationOptions.None,
importantTaskScheduler);
}
else
{
Task.Factory.StartNew(OtherHandler, pair.Value, CancellationToken.None, TaskCreationOptions.None,
otherTaskScheduler);
}
}
private static void ImportantHandler(Object value)
{
// Обработка важных ключей
// Типа долго
Thread.Sleep(5000);
Console.WriteLine(value);
}
private static void OtherHandler(Object value)
{
// Обработка остальных ключей
Console.WriteLine(value);
}
}
Что здесь происходит?
Для важных ключей создается свой диспетчер задач, а для не важных соответственно свой (при этом задачи в каждом диспетчере будут выполняться последовательно, благодаря классу
LimitedConcurrencyLevelTaskScheduler с параметром 1).
Далее метод Process принимает на обработку очередную порцию данных, если это важный ключ, запускает выполнения метода ImportantHandler с указанным диспетчером задач. Если ключ не важный, то запускается OtherHandler.
В выводе программы, можно заметить (специально поставил Sleep), что обработка важных ключей выполняется последовательно.
Данный вариант можно расширить и для каждого ключа создавать свой диспетчер, с помощью которого и запускать обработку этих ключей.
